kazoo.handlers.utils

Kazoo handler helpers

Public API

kazoo.handlers.utils.capture_exceptions(async_result)

Return a new decorated function that propagates the exceptions of the wrapped function to an async_result.

Parameters:

async_result (IAsyncResult) – An async result implementing IAsyncResult

Return type:

Callable[[Callable[[ParamSpec(GenericArgs, bound= None)], TypeVar(CapturedResult)]], Callable[[ParamSpec(GenericArgs, bound= None)], TypeVar(CapturedResult) | None]]

kazoo.handlers.utils.wrap(async_result)

Return a new decorated function that propagates the return value or exception of wrapped function to an async_result. NOTE: Only propagates a non-None return value.

Parameters:

async_result (IAsyncResult) – An async result implementing IAsyncResult

Return type:

Callable[[Callable[[ParamSpec(GenericArgs, bound= None)], TypeVar(CapturedResult)]], Callable[[ParamSpec(GenericArgs, bound= None)], TypeVar(CapturedResult) | None]]

Private API

kazoo.handlers.utils.create_socket_pair(module, port=0)

Create socket pair.

If socket.socketpair isn’t available, we emulate it.

Return type:

tuple[Socket, Socket]

kazoo.handlers.utils.create_tcp_socket(module)

Create a TCP socket with the CLOEXEC flag set.

Return type:

Socket