server

Module: broker::server

Contents

Structs

• BrokerListener - Broker-side listener: accepts shim connections and dispatches requests.

Enums

• AcceptError - Error from [BrokerListener::accept_one], split by whether the listener

---

firma_secret_provider::broker::server::AcceptError

Enum

Error from [BrokerListener::accept_one], split by whether the listener can keep serving.

Listener errors mean the listener itself failed (e.g. the socket can no longer accept); a loop should stop. Connection errors affect only the current peer (timeout, malformed framing, I/O failure, rejected peer credentials); the listener stays usable and a robust loop must keep accepting.

Variants:

• Listener(std::io::Error) - The listener socket failed and can no longer accept connections.
• Connection(std::io::Error) - One accepted connection failed before completing the exchange.

Methods:

• fn kind(self: &Self) -> std::io::ErrorKind - The underlying [std::io::ErrorKind] of the wrapped I/O error.

Trait Implementations:

• Display
  • fn fmt(self: &Self, __formatter: & mut ::core::fmt::Formatter) -> ::core::fmt::Result
• Error
  • fn source(self: &Self) -> ::core::option::Option<&dyn ::thiserror::__private18::Error>
• Debug
  • fn fmt(self: &Self, f: & mut $crate::fmt::Formatter) -> $crate::fmt::Result

firma_secret_provider::broker::server::BrokerListener

Struct

Broker-side listener: accepts shim connections and dispatches requests.

Methods:

• fn bind(endpoint: &ServerEndpoint, config: BrokerConfig) -> io::Result<Self> - Bind a listener at endpoint with config.
• fn config(self: &Self) -> BrokerConfig - The broker configuration this listener applies to each connection.
• fn bound_endpoint(self: &Self) -> io::Result<EndpointInner> - Return the address this listener is actually bound to.
• fn accept_one<F>(self: &Self, handler: F) -> Result<(), AcceptError> - Accept one shim connection, invoke handler(request), and write the

Trait Implementations:

• Drop
  • fn drop(self: & mut Self)