Struct ServerState 

pub struct ServerState { /* private fields */ }

Cloneable shared state passed to all server transports.

Implementations

impl ServerState

pub async fn build(config: ServerConfig) -> Result<Self, ServerError>

Build shared state from operator configuration.

Errors

Returns ServerError if the store cannot connect or the engine cannot be constructed.

pub async fn build_with_store<S>( store: S, runtime: RuntimeConfig, ) -> Result<Self, ServerError>

where S: EventStore,

Build shared state from an already-constructed store.

Errors

Returns ServerError::EngineCall if the engine cannot be constructed.

pub fn from_parts( namespace_resolver: NamespaceResolver, runtime: RuntimeConfig, ) -> Self

Build shared state from explicit parts with a default worker registry.

pub fn from_parts_with_registry( namespace_resolver: NamespaceResolver, runtime: RuntimeConfig, worker_registry: ConnectedWorkerRegistry, ) -> Self

Build shared state from explicit parts with a caller-supplied registry.

pub fn namespace_guard(&self) -> &NamespaceGuard

Borrow the namespace guard shared by all transports.

pub fn deploy_guard(&self) -> DeployGuard

Build the deploy authorization guard over the shared resolver.

pub fn runtime_config(&self) -> &RuntimeConfig

Borrow non-secret runtime settings needed by transports.

pub fn worker_registry(&self) -> &ConnectedWorkerRegistry

Borrow the connected-worker registry shared by worker transports and dispatch.

pub fn pending_activities(&self) -> &PendingActivities

Borrow the pending-activities tracker shared by the NIF bridge and worker stream handler.

pub fn heartbeat_tracker(&self) -> &HeartbeatTracker

Borrow the heartbeat/liveness tracker shared by dispatch and worker streams.

pub fn drain_state(&self) -> &DrainState

Borrow the drain gate shared by transports and worker dispatch.

pub fn metrics(&self) -> Option<&Metrics>

Borrow the prometheus metrics handle when this state was built with a store.

pub fn health(&self) -> Option<&HealthState>

Borrow health probe state when this state was built with a store.

pub fn shutdown(&self) -> Result<(), ServerError>

Shut down the embedded engine so in-flight durable appends can finish.

Errors

Returns ServerError if the namespace resolver has no engine handle or the engine rejects shutdown.

Trait Implementations

impl Clone for ServerState

fn clone(&self) -> ServerState

Returns a duplicate of the value.

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

Performs copy-assignment from source.