Struct GatewayClientTransportBridge 

pub struct GatewayClientTransportBridge { /* private fields */ }

Low-level bridge from client packet transport into the gateway command pipeline.

Implementations

impl GatewayClientTransportBridge

pub const fn new() -> Self

Creates a gateway client transport bridge.

pub const fn stats(&self) -> GatewayClientTransportStats

Returns accumulated statistics.

pub fn pump_ingress<T, E>( &mut self, transport: &mut T, pipeline: &mut GatewayCommandPipeline, gateway: &mut GatewaySessionTable, station_queues: &mut BTreeMap<StationId, CommandQueues>, now: Tick, ingress: CommandIngress, max_packets: usize, ) -> Result<GatewayClientTransportPump, GatewayClientTransportError<E>>

where T: TransportReceiver<Error = E> + TransportSink<Error = E>,

Pumps up to max_packets client command packets into station queues and sends produced ACKs back through the same bounded client transport.

pub fn pump_ingress_compact<T, E>( &mut self, transport: &mut T, pipeline: &mut GatewayCommandPipeline, gateway: &mut GatewaySessionTable, station_queues: &mut BTreeMap<StationId, CommandQueues>, now: Tick, ingress: CommandIngress, max_packets: usize, ) -> Result<GatewayClientTransportSummary, GatewayClientTransportError<E>>

where T: TransportReceiver<Error = E> + TransportSink<Error = E>,

Pumps commands and moves ACK buffers directly into transport without retaining per-command pipeline reports.

Use Self::pump_ingress when the caller needs detailed error reports or encoded ACK bytes after sending.

Trait Implementations

impl Clone for GatewayClientTransportBridge

fn clone(&self) -> GatewayClientTransportBridge

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GatewayClientTransportBridge

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

Formats the value using the given formatter.

impl Default for GatewayClientTransportBridge

fn default() -> GatewayClientTransportBridge

Returns the “default value” for a type.