Struct BrokerServeConfig 

pub struct BrokerServeConfig {
    pub socket_path: String,
    pub service_name: String,
    pub service_version: String,
    pub backend_endpoint: String,
    pub service_definition_dir: PathBuf,
    pub max_connections: Option<NonZeroUsize>,
    pub handoff_endpoint: Option<String>,
}

Configuration for a bounded broker serve-mode run.

Fields

socket_path: String

Local socket path or Windows pipe name to bind.

service_name: String

Service definition to load.

service_version: String

Backend version to register for Hello negotiation.

backend_endpoint: String

Direct backend endpoint returned to negotiated clients.

service_definition_dir: PathBuf

Directory containing <service>.servicedef protobuf files.

max_connections: Option<NonZeroUsize>

Optional number of control-socket connections to accept before returning.

handoff_endpoint: Option<String>

Optional backend handoff endpoint enabling the Phase 6 handle-passing optimization (#387). None (the default) disables handoff entirely: negotiated clients always reconnect through backend_endpoint. This matches the opt-in Phase 6 gate in docs/v1-rollout-policy.md.

Implementations

impl BrokerServeConfig

pub fn new( socket_path: impl Into<String>, service_name: impl Into<String>, service_version: impl Into<String>, backend_endpoint: impl Into<String>, max_connections: usize, ) -> Result<Self, BrokerServeError>

Build a serve config using the platform service-definition directory.

pub fn unbounded( socket_path: impl Into<String>, service_name: impl Into<String>, service_version: impl Into<String>, backend_endpoint: impl Into<String>, ) -> Self

Build an unbounded serve config using the platform service-definition directory.

pub fn with_service_definition_dir(self, root: impl Into<PathBuf>) -> Self

Override the service-definition directory.

pub fn with_handoff_endpoint(self, endpoint: impl Into<String>) -> Self

Opt in to the Phase 6 handle-passing handoff by configuring the backend handoff endpoint the broker dials after negotiation (#387).

pub fn connection_limit(&self) -> ControlSocketConnectionLimit

Return the configured accept-loop connection limit.

Trait Implementations

impl Clone for BrokerServeConfig

fn clone(&self) -> BrokerServeConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BrokerServeConfig

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

Formats the value using the given formatter.