Struct GatewayCommandPipeline 

pub struct GatewayCommandPipeline { /* private fields */ }

Business-agnostic gateway command frame pipeline.

Implementations

impl GatewayCommandPipeline

pub fn new(config: GatewayCommandPipelineConfig) -> Self

Creates a pipeline.

pub const fn config(&self) -> GatewayCommandPipelineConfig

Returns configuration.

pub const fn stats(&self) -> GatewayCommandPipelineStats

Returns statistics.

pub fn process( &mut self, gateway: &mut GatewaySessionTable, station_queues: &mut BTreeMap<StationId, CommandQueues>, input: &[u8], now: Tick, ingress: CommandIngress, ) -> GatewayCommandPipelineReport

Processes one decoded-transport command packet and optionally produces an encoded command ACK.

pub fn dispatch( &mut self, gateway: &mut GatewaySessionTable, deployment: &DeploymentRouteTable, input: &[u8], now: Tick, ) -> GatewayCommandPipelineReport

Decodes and admits one command packet, then resolves a deployment route for external node dispatch without touching local station queues.

Trait Implementations

impl Clone for GatewayCommandPipeline

fn clone(&self) -> GatewayCommandPipeline

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GatewayCommandPipeline

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

Formats the value using the given formatter.

impl Default for GatewayCommandPipeline

fn default() -> Self

Returns the “default value” for a type.