Module connection 

Framed broker connection handling for the v1 Hello path.

This module keeps the wire I/O boundary separate from HelloHandler. The long-lived accept loop can call the same single-connection function after binding the platform pipe/socket and verifying peer credentials.

Enums

BrokerConnectionError

Errors raised while serving a framed broker Hello connection.

PeerCredentialPolicy

Peer credential policy applied before reading a Hello frame.

Traits

HelloResponder

Handles a decoded broker Hello frame and returns the protocol reply.

Functions

handle_hello_connection

Handle one already-accepted broker connection.

handle_hello_connection_with

Handle one already-accepted broker connection with a pluggable responder.

handle_hello_connection_with_peer_policy

Handle one already-accepted broker connection with an explicit peer policy.

local_socket_name

Convert the broker’s platform socket path/name string into an interprocess local-socket name.

serve_local_socket_connections

Run a bounded blocking local-socket accept loop.

serve_local_socket_connections_with

Run a bounded blocking local-socket accept loop with a pluggable responder.

serve_local_socket_connections_with_peer_policy

Run a bounded blocking local-socket accept loop with an explicit peer policy.

serve_local_socket_connections_with_policy

Run a bounded pluggable-responder accept loop with an explicit peer policy.

serve_one_local_socket

Run one blocking local-socket accept and serve exactly one Hello.

serve_one_local_socket_with

Run one blocking local-socket accept and serve exactly one Hello with a pluggable responder.

serve_one_local_socket_with_peer_policy

Run one blocking local-socket accept with an explicit peer policy.