Enum ServerError 

pub enum ServerError {
    ConfigLoad {
        message: String,
    },
    ConfigValidation {
        message: String,
    },
    ListenerBind {
        address: SocketAddr,
        source: Error,
    },
    ListenerAccept {
        message: String,
    },
    ParticipantIncarnation {
        phase: &'static str,
        message: String,
    },
    ServerIncarnationExhausted,
    ParticipantStartupRestore {
        message: String,
    },
    ConnectionIncarnationExhausted {
        attempted_server_incarnation: u64,
    },
    UnsupportedOperation {
        operation: String,
        profile: &'static str,
    },
    PushReplyDisconnected {
        correlation_id: u64,
    },
    PushReplyTimeout {
        correlation_id: u64,
    },
    PushReplyExpired {
        correlation_id: u64,
    },
    ClusterJoin {
        message: String,
    },
    ClusterSync {
        message: String,
    },
    ShutdownTimeout {
        message: String,
    },
    ShutdownFlush {
        message: String,
    },
    HealthEndpoint {
        message: String,
    },
    ConnectionLimitReached {
        limit: usize,
    },
    ConnectionCapReached {
        operation: String,
        cap: &'static str,
        limit: usize,
    },
}

Error taxonomy for standalone liminal server deployment failures.

Variants

ConfigLoad

The configuration file could not be read or parsed.

Fields

message: String

ConfigValidation

The configuration file was read but failed semantic validation.

Fields

message: String

ListenerBind

The server could not bind its configured listener address.

Fields

address: SocketAddr

Address the server attempted to bind.

source: Error

Underlying operating-system bind failure.

ListenerAccept

The server listener failed while accepting an inbound connection.

Fields

message: String

ParticipantIncarnation

Durable participant-incarnation startup or allocation failed before its result could be published.

Fields

phase: &'static str

Exact server seam that failed.

message: String

Underlying durable or bounded-bridge diagnostic.

ServerIncarnationExhausted

The durable server-incarnation namespace has no successor.

ParticipantStartupRestore

Production participant startup restore failed: the durable conversation streams could not be scanned or replayed, so the server-scope capacity ledger cannot be made exact and the server refuses to start over state it cannot account for.

Fields

message: String

Underlying durable, replay, or bridge diagnostic.

ConnectionIncarnationExhausted

The current durable server incarnation has no collision-free connection ordinal left, so the accepted socket was not admitted.

Fields

attempted_server_incarnation: u64

Server incarnation whose complete ordinal suffix was examined.

UnsupportedOperation

A frame requested an operation the configured services profile does not serve (e.g. ordinary publish/subscribe/conversation traffic against the capability-scoped worker front door). Server-internal taxonomy, not wire vocabulary: the connection process renders it as the operation’s existing typed error frame with this error’s text as the message.

Fields

operation: String

Human-readable description of the refused operation.

profile: &'static str

The configured services profile that refused it.

PushReplyDisconnected

A server→client push reply slot was dropped before a correlated reply arrived — the connection closed (the prompt worker-death signal). Distinct from Self::PushReplyTimeout so consumers can tell a worker that DIED (fast failover) from one that is merely SLOW, by type rather than message.

Fields

correlation_id: u64

Correlation id of the push whose reply will never arrive.

PushReplyTimeout

A server→client push reply did not arrive within the awaiter’s timeout — the worker is still connected but did not reply in this wait quantum. This is BENIGN: the reply slot survives untouched and the caller may re-arm PushReplyAwaiter::receive indefinitely. It is not a worker-death signal.

Fields

correlation_id: u64

Correlation id of the push whose wait quantum elapsed.

PushReplyExpired

A server→client push carrying an explicit reply deadline (via push_to_connection_with_deadline) reached that deadline before a correlated reply arrived. Unlike Self::PushReplyTimeout this is TERMINAL: the reply slot has been removed and its §5 max_pending_pushes_per_connection cap admission released. Returned PROMPTLY once the deadline is due — a receive call does not hold a due expiry until its caller’s quantum ends, so the terminal outcome is independent of how the caller polls. Distinct variant so callers classify by type, not message.

Fields

correlation_id: u64

Correlation id of the push whose reply deadline passed.

ClusterJoin

The server could not join the configured beamr distribution cluster.

Fields

message: String

ClusterSync

Cluster state propagation through beamr distribution failed.

Fields

message: String

ShutdownTimeout

Graceful shutdown did not drain within the configured timeout.

Fields

message: String

ShutdownFlush

Durable state could not be flushed during graceful shutdown.

Fields

message: String

HealthEndpoint

The health endpoint failed to start or serve requests.

Fields

message: String

ConnectionLimitReached

A new connection was refused because the configured max_connections cap (§5) is already reached. The listener drops the freshly accepted stream, refusing the connection, rather than admitting an unbounded fleet.

Fields

limit: usize

The configured max_connections cap that was hit.

ConnectionCapReached

An admission-time per-connection cap (§5) refused an operation: too many subscriptions, conversations, in-flight pushes, or pending conversation replies on one connection. The connection process renders it as the operation’s existing typed error frame with this text as the message.

Fields

operation: String

Human-readable description of the refused operation.

cap: &'static str

The name of the cap that refused it (a limits.* config key).

limit: usize

The configured cap value that was hit.

Trait Implementations

impl Debug for ServerError

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

Formats the value using the given formatter.

impl Display for ServerError

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

Formats the value using the given formatter.

impl Error for ServerError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.