Struct InMemoryStationTransport 

pub struct InMemoryStationTransport { /* private fields */ }

Bounded in-memory station-to-station packet transport.

Implementations

impl InMemoryStationTransport

pub fn new(limits: StationTransportLimits) -> Self

Creates an empty bounded station transport.

pub fn register_station(&mut self, station_id: StationId)

Registers a target station queue.

pub fn unregister_station(&mut self, station_id: StationId) -> Option<usize>

Unregisters a station and releases its queued packet storage.

pub fn queued_len(&self, station_id: StationId) -> Option<usize>

Returns queued packet count for a station.

pub fn queued_capacity(&self, station_id: StationId) -> Option<usize>

Returns packet slots retained by one station queue.

pub fn retained_queue_capacity(&self) -> usize

Returns packet slots retained across all registered station queues.

pub const fn limits(&self) -> StationTransportLimits

Returns configured limits.

pub const fn stats(&self) -> InMemoryStationTransportStats

Returns transport statistics.

Trait Implementations

impl Clone for InMemoryStationTransport

fn clone(&self) -> InMemoryStationTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryStationTransport

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

Formats the value using the given formatter.

impl Default for InMemoryStationTransport

fn default() -> Self

Returns the “default value” for a type.

impl StationTransportReceiver for InMemoryStationTransport

type Error = StationTransportError

Transport error type.

fn try_recv_station( &mut self, target_station: StationId, ) -> Result<Option<StationInboundPacket>, Self::Error>

Attempts to receive one encoded packet for target_station.

impl StationTransportSink for InMemoryStationTransport

type Error = StationTransportError

Transport error type.

fn send_station( &mut self, packet: StationOutboundPacket, ) -> Result<(), Self::Error>

Sends one encoded station packet.

fn send_station_batch( &mut self, batch: StationPacketBatch, ) -> Result<(), Self::Error>

Sends a station packet batch.