Skip to main content

Module control_socket

Module control_socket 

Source
Expand description

Shared broker control socket dispatch for Hello and admin frames.

The v1 broker uses one local socket for both client Hello negotiation and admin verbs. This module keeps the bounded synchronous serve helpers aligned with that contract while the long-lived daemon loop is still being built.

Enums§

ControlSocketConnectionLimit
Connection limit for a broker control-socket accept loop.
ControlSocketError
Errors raised while dispatching a shared broker control socket frame.
ControlSocketReply
Result of handling one control socket connection.

Functions§

handle_control_connection_with_peer_policy
Handle one already-accepted broker control connection.
serve_control_socket_connections_with_limit_and_policy
Run a broker control-socket accept loop that dispatches Hello and admin frames on the same endpoint.
serve_control_socket_connections_with_policy
Run a bounded local-socket accept loop that dispatches Hello and admin frames on the same endpoint.