Struct ReplicationReceiveBridge 

pub struct ReplicationReceiveBridge { /* private fields */ }

Bridge between client packet transport and decoded replication frames.

Implementations

impl ReplicationReceiveBridge

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

Creates a receive bridge.

pub const fn config(&self) -> ReplicationReceiveConfig

Returns configuration.

pub const fn stats(&self) -> ReplicationReceiveStats

Returns accumulated statistics.

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

where T: TransportReceiver,

Receives and decodes up to max_packets replication frames.

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

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

Receives validated replication frames and visits borrowed deltas without materializing nested owned frame storage.

The visitor must consume borrowed component bytes before returning. Its error is surfaced separately from transport and frame-validation errors. A frame is counted as accepted after source/wire/target validation and before visitor invocation; accumulated bridge statistics are not rolled back when the visitor returns an error.

Trait Implementations

impl Clone for ReplicationReceiveBridge

fn clone(&self) -> ReplicationReceiveBridge

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicationReceiveBridge

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

Formats the value using the given formatter.