Struct HelloHandler 

pub struct HelloHandler { /* private fields */ }

Deterministic Hello handler over an in-memory backend table.

Implementations

impl HelloHandler

pub fn new() -> Self

Create an empty handler.

pub fn with_handoff_ack_deadline(self, ack_deadline: Duration) -> Self

Override the backend ACK deadline for pending handoffs.

pub fn handoff_token_store(&self) -> MutexGuard<'_, HandoffTokenStore>

Lock the pending handoff token store owned by this handler.

The backend-side acceptance path (backend_lib::accept_handed_off) consumes pending tokens from this store exactly once.

pub fn handoff_ack_registry(&self) -> MutexGuard<'_, HandoffAckRegistry>

Lock the pending handoff ACK registry owned by this handler.

Every token issued during Hello negotiation is registered here and must be acknowledged via HelloHandler::acknowledge_handoff before the ACK deadline, or it is abandoned by HelloHandler::expire_overdue_handoffs.

pub fn acknowledge_handoff( &self, token: &HandoffToken, now: Instant, ) -> Result<AcknowledgedHandoff, HandoffAckError>

Record that the backend adopted a handed-off connection.

Completes the pending handoff registered at Hello time and revokes the one-time token. Lock order: ACK registry, then token store.

pub fn expire_overdue_handoffs(&self, now: Instant) -> Vec<ExpiredHandoff>

Abandon every pending handoff whose backend ACK deadline has passed.

Each returned expiry has had its token revoked; callers must use the backend_pipe reconnect fallback for the affected connections.

pub fn with_rate_limit(self, max_per_window: u32, window: Duration) -> Self

Override the per-peer Hello rate limit.

pub fn with_backend( self, backend: RegisteredBackend, ) -> Result<Self, HelloHandlerError>

Register a backend by its service definition’s service name.

pub fn handle_frame(&self, frame: Frame, peer: PeerIdentity) -> HelloReply

Decode and handle a framed v1 Hello request.

pub fn handle_request(&self, request: &HelloRequest) -> HelloReply

Validate a decoded Hello request and return a v1 HelloReply.

Trait Implementations

impl Debug for HelloHandler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for HelloHandler

fn default() -> Self

Returns the “default value” for a type.

impl HelloResponder for HelloHandler

fn handle_frame(&self, frame: Frame, peer: PeerIdentity) -> HelloReply

Decode and answer a broker Hello frame for an OS-verified peer.