Struct ConnectionSupervisor 

pub struct ConnectionSupervisor { /* private fields */ }

Supervisor that owns the beamr scheduler for per-connection processes.

Implementations

impl ConnectionSupervisor

pub fn from_config(config: &ServerConfig) -> Result<Self, ServerError>

Creates a connection supervisor backed by the configured liminal channels.

Errors

Returns ServerError when channel initialization or scheduler startup fails.

pub fn new() -> Result<Self, ServerError>

Creates a connection supervisor with no configured channels.

Errors

Returns ServerError when scheduler startup fails.

pub fn with_services( services: Arc<dyn ConnectionServices>, ) -> Result<Self, ServerError>

Creates a connection supervisor using an explicit service adapter.

Errors

Returns ServerError when scheduler startup fails.

pub fn with_services_and_notifier( services: Arc<dyn ConnectionServices>, notifier: Arc<dyn ConnectionNotifier>, ) -> Result<Self, ServerError>

Creates a connection supervisor with an explicit service adapter and a connection-keyed worker-registration notifier.

The notifier is invoked when a worker registers on a connection and when such a connection closes. Supervisors built via Self::with_services, Self::from_config, or Self::new carry no notifier, so liminal still runs standalone; a WorkerRegister frame is then accepted without any application callback.

Errors

Returns ServerError when scheduler startup fails.

pub fn spawn_connection( &self, stream: TcpStream, ) -> Result<ConnectionHandle, ServerError>

Spawns one supervised beamr process that owns stream.

Errors

Returns ServerError when stream configuration or beamr spawn fails.

pub fn scheduler(&self) -> Arc<Scheduler>

Returns the underlying beamr scheduler.

pub fn reap_crashed_connections(&self) -> usize

Reaps connection processes that have exited outside the normal handler path.

pub fn is_tracked(&self, pid: u64) -> bool

Returns true when pid is still tracked by the supervisor.

pub fn active_connection_count(&self) -> usize

Returns the number of tracked live connections.

pub fn active_connection_pids(&self) -> Vec<u64>

Returns the beamr process ids of the currently tracked live connections.

Useful for addressing a specific connection — e.g. as the pid argument to push_to_connection when the caller knows there is a single connected client.

pub fn notify_shutdown_subscribers(&self)

Broadcasts a best-effort shutdown notification to active connections.

Connections with no active subscriptions ignore the notification. Failures to enqueue the control message are logged and skipped; they are not retried.

pub fn force_close_active_connections(&self)

Sends a force-close control message to every tracked connection process.

Each live process attempts one shutdown notification before closing its stream and exiting normally. Enqueue failures are logged and skipped.

pub fn push_to_connection( &self, pid: u64, payload: Vec<u8>, ) -> Result<PushReplyAwaiter, ServerError>

Pushes an opaque payload to a specific connected client over that client’s existing connection and returns an awaiter for the client’s correlated reply.

This is the server-initiated leg (server-to-client), the inverse of every other request frame. It allocates a correlation id, registers a one-shot reply slot keyed by that id, and enqueues a [ConnectionControl::Push] for the connection process owning pid; that process writes a [Frame::Push] out on its socket. When the client answers with a PushReply carrying the same correlation id, the connection process resolves the awaiter’s slot. The returned PushReplyAwaiter blocks (bounded) for that reply.

Errors

Returns ServerError when the correlation id cannot be allocated, the reply slot cannot be registered, or the control message cannot be enqueued for the (possibly already-gone) connection process.

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

Flushes durable channel state through the configured liminal services.

Errors

Returns ServerError::ShutdownFlush when the underlying service flush fails.

pub fn shutdown(&self)

Stops the beamr scheduler used by connection processes.

Trait Implementations

impl Clone for ConnectionSupervisor

fn clone(&self) -> ConnectionSupervisor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectionSupervisor

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

Formats the value using the given formatter.