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§
- Control
Socket Connection Limit - Connection limit for a broker control-socket accept loop.
- Control
Socket Error - Errors raised while dispatching a shared broker control socket frame.
- Control
Socket Reply - Result of handling one control socket connection.
Functions§
- handle_
control_ connection_ with_ peer_ policy - Handle one already-accepted broker control connection.
- handle_
control_ connection_ with_ peer_ policy_ and_ fd_ guard - Handle one already-accepted broker control connection, refusing Hello
frames with
ERROR_FD_PRESSUREwhilefd_guardreports a demotion (#390). Admin frames are always served sostatuscan surface the demoted state. - 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_ limit_ policy_ and_ post_ hello - Run a broker control-socket accept loop with a post-Hello connection hook.
- serve_
control_ socket_ connections_ with_ limit_ policy_ post_ hello_ and_ fd_ guard - Run a broker control-socket accept loop with fd-pressure self-demotion (#390).
- serve_
control_ socket_ connections_ with_ policy - Run a bounded local-socket accept loop that dispatches Hello and admin frames on the same endpoint.