Struct DeploymentRouteTable 

pub struct DeploymentRouteTable { /* private fields */ }

Bounded station-to-node deployment route table.

Implementations

impl DeploymentRouteTable

pub fn new(config: DeploymentConfig) -> Self

Creates an empty deployment route table.

pub const fn config(&self) -> DeploymentConfig

Returns configuration.

pub const fn stats(&self) -> DeploymentStats

Returns statistics.

pub fn node_len(&self) -> usize

Returns registered node count.

pub fn station_len(&self) -> usize

Returns station route count.

pub fn register_node( &mut self, node_id: NodeId, station_capacity: usize, now: Tick, ) -> Result<DeploymentNodeRoute, DeploymentError>

Registers or refreshes a node.

pub fn heartbeat( &mut self, node_id: NodeId, now: Tick, ) -> Result<DeploymentNodeRoute, DeploymentError>

Updates a node heartbeat.

pub fn mark_draining( &mut self, node_id: NodeId, ) -> Result<DeploymentNodeRoute, DeploymentError>

Marks a node draining. Existing station routes remain valid.

pub fn mark_offline( &mut self, node_id: NodeId, ) -> Result<DeploymentNodeRoute, DeploymentError>

Marks a node offline. Station routes are retained for explicit remediation by the embedder.

pub fn assign_station( &mut self, station_id: StationId, node_id: NodeId, now: Tick, ) -> Result<DeploymentStationRoute, DeploymentError>

Assigns a station to an online node.

pub fn move_station( &mut self, station_id: StationId, target_node: NodeId, now: Tick, ) -> Result<DeploymentStationMove, DeploymentError>

Moves an existing station route to another online node.

pub fn unassign_station( &mut self, station_id: StationId, ) -> Result<DeploymentStationRoute, DeploymentError>

Removes one station route.

pub fn node_route( &self, node_id: NodeId, ) -> Result<DeploymentNodeRoute, DeploymentError>

Returns a node route.

pub fn station_route( &self, station_id: StationId, ) -> Result<DeploymentStationRoute, DeploymentError>

Returns a station route.

pub fn stations_on_node( &self, node_id: NodeId, ) -> Result<Vec<StationId>, DeploymentError>

Returns station ids assigned to a node.

pub fn resolve_gateway_route( &self, route: GatewayRoute, ) -> Result<GatewayDeliveryRoute, DeploymentError>

Resolves a gateway route to deployment node/station metadata.

Draining nodes remain valid for existing station routes; offline nodes are rejected so embedders can reroute or fail over explicitly.

pub fn resolve_gateway_client( &self, gateway: &GatewaySessionTable, client_id: ClientId, ) -> Result<GatewayDeliveryRoute, GatewayDeliveryError>

Resolves a connected gateway client to deployment node/station metadata.

pub fn stale_nodes(&self, now: Tick) -> Vec<NodeId>

Returns stale node ids without mutating node state.

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

Marks stale nodes offline.

Trait Implementations

impl Clone for DeploymentRouteTable

fn clone(&self) -> DeploymentRouteTable

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeploymentRouteTable

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

Formats the value using the given formatter.

impl Default for DeploymentRouteTable

fn default() -> Self

Returns the “default value” for a type.