Struct CommandDispatchTransportBridge 

pub struct CommandDispatchTransportBridge { /* private fields */ }

Bridge between stamped command envelopes and bounded station packet transport.

Implementations

impl CommandDispatchTransportBridge

pub const fn stats(&self) -> CommandDispatchTransportStats

Returns bridge statistics.

pub fn send_envelope<T>( &mut self, transport: &mut T, source_station: StationId, target_station: StationId, command: &CommandEnvelope, ) -> Result<(), CommandDispatchTransportError<T::Error>>

where T: StationTransportSink,

Encodes and sends a stamped command envelope to a station node.

pub fn send_frame<T>( &mut self, transport: &mut T, source_station: StationId, frame: &CommandDispatchFrame, ) -> Result<(), CommandDispatchTransportError<T::Error>>

where T: StationTransportSink,

Encodes and sends a command dispatch frame to its target station.

pub fn pump_target<T>( &mut self, transport: &mut T, station_queues: &mut BTreeMap<StationId, CommandQueues>, target_station: StationId, max_packets: usize, ingress: CommandIngress, ) -> Result<CommandDispatchPumpReport, CommandDispatchTransportError<T::Error>>

where T: StationTransportReceiver,

Receives up to max_packets for target_station, decodes command dispatch frames, and enqueues stamped commands into station_queues.

Trait Implementations

impl Clone for CommandDispatchTransportBridge

fn clone(&self) -> CommandDispatchTransportBridge

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CommandDispatchTransportBridge

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

Formats the value using the given formatter.

impl Default for CommandDispatchTransportBridge

fn default() -> CommandDispatchTransportBridge

Returns the “default value” for a type.