Struct ClientTransportBridge 

pub struct ClientTransportBridge { /* private fields */ }

Low-level bridge for client command send and client-bound frame receive.

Implementations

impl ClientTransportBridge

pub const fn new(config: ClientTransportConfig) -> Self

Creates a client transport bridge.

pub const fn config(&self) -> ClientTransportConfig

Returns configuration.

pub const fn stats(&self) -> ClientTransportStats

Returns accumulated statistics.

pub fn send_command_frame<T>( &mut self, transport: &mut T, frame: &CommandFrame, ) -> Result<ClientCommandSendReport, ClientTransportBridgeError<T::Error>>

where T: TransportSink,

Encodes and sends a client command frame to the configured server id.

pub fn pump_owned<T>( &mut self, transport: &mut T, max_packets: usize, ) -> Result<ClientTransportPump, ClientTransportBridgeError<T::Error>>

where T: TransportReceiver,

Receives and decodes up to max_packets client-bound frames.

pub fn pump<T, F, V>( &mut self, transport: &mut T, max_packets: usize, visitor: F, ) -> Result<ClientTransportVisitReport, ClientTransportVisitError<T::Error, V>>

where T: TransportReceiver, F: for<'frame> FnMut(ClientInboundFrameRef<'frame>) -> Result<(), V>,

Receives mixed client-bound frames and visits them without materializing nested replication frame storage.

ACK and barrier values are copied into the visitor enum. Replication component bytes borrow the current transport packet and must be consumed before the visitor returns. Accepted statistics are recorded before visitor invocation and are not rolled back if the visitor fails.

Trait Implementations

impl Clone for ClientTransportBridge

fn clone(&self) -> ClientTransportBridge

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClientTransportBridge

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

Formats the value using the given formatter.