Struct GatewaySessionTable 

pub struct GatewaySessionTable { /* private fields */ }

Bounded in-memory gateway session and route table.

Implementations

impl GatewaySessionTable

pub fn new(config: GatewayConfig) -> Self

Creates an empty gateway session table.

pub const fn config(&self) -> GatewayConfig

Returns configuration.

pub const fn stats(&self) -> GatewayStats

Returns statistics.

pub fn len(&self) -> usize

Returns tracked session count.

pub fn is_empty(&self) -> bool

Returns whether no sessions are tracked.

pub fn session(&self, client_id: ClientId) -> Option<&GatewaySession>

Returns a session by client id.

pub fn route(&self, client_id: ClientId) -> Result<GatewayRoute, GatewayError>

Returns a connected route by client id.

pub fn connect( &mut self, client_id: ClientId, station_id: StationId, now: Tick, ) -> Result<GatewayConnectReport, GatewayError>

Connects a client, reconnecting within grace or replacing stale sessions.

pub fn reconnect( &mut self, client_id: ClientId, generation: u64, now: Tick, ) -> Result<GatewayConnectReport, GatewayError>

Reconnects a disconnected client by generation.

pub fn disconnect( &mut self, client_id: ClientId, now: Tick, ) -> Result<(), GatewayError>

Marks a connected session disconnected.

pub fn expire_disconnected(&mut self, now: Tick) -> usize

Removes disconnected sessions whose grace window has expired.

pub fn expiry_deadline_len(&self) -> usize

Deadline entries retained for caller-driven expiry maintenance.

pub fn expiry_deadline_capacity(&self) -> usize

Allocated deadline-entry capacity retained by the table.

pub fn reroute( &mut self, client_id: ClientId, station_id: StationId, now: Tick, ) -> Result<GatewayRoute, GatewayError>

Changes the target station for a connected client.

pub fn admit_command( &mut self, command: &CommandEnvelope, ) -> Result<GatewayCommandAdmission, GatewayError>

Applies session metadata checks to a command and returns the route that should receive it.

pub fn admit_sequence( &mut self, client_id: ClientId, sequence: u64, now: Tick, ) -> Result<GatewayCommandAdmission, GatewayError>

Applies session metadata checks to a client command sequence.

Trait Implementations

impl Clone for GatewaySessionTable

fn clone(&self) -> GatewaySessionTable

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GatewaySessionTable

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

Formats the value using the given formatter.

impl Default for GatewaySessionTable

fn default() -> Self

Returns the “default value” for a type.