Struct ReplicationReceiver 

pub struct ReplicationReceiver { /* private fields */ }

Replication receiver state machine.

Implementations

impl ReplicationReceiver

pub fn with_config(config: ReceiverConfig) -> Self

Create a new receiver with explicit configuration.

pub fn new() -> Self

Create a new receiver in LISTENING state.

pub const fn state(&self) -> ReceiverState

Current state.

pub const fn applied_count(&self) -> u64

Number of changesets successfully applied.

pub fn active_decoders(&self) -> usize

Number of active decoder sessions.

pub fn decode_audit_entries(&self) -> &[DecodeAuditEntry]

View decode-proof audit entries emitted so far.

pub fn take_decode_audit_entries(&mut self) -> Vec<DecodeAuditEntry>

Drain decode-proof audit entries.

pub fn process_packet(&mut self, packet_bytes: &[u8]) -> Result<PacketResult>

Process a raw packet from the wire.

Errors

Returns error if:

• Packet is malformed (too short, symbol_size = 0)
• V1 rule violated (SBN != 0)
• K_source out of range
• K_source or symbol_size mismatch for existing decoder

pub fn process_parsed_packet( &mut self, packet: &ReplicationPacket, ) -> Result<PacketResult>

Process a parsed packet.

Errors

See process_packet.

pub fn apply_pending(&mut self) -> Result<Vec<DecodeResult>>

Apply pending decoded results. Returns applied page counts.

In production, this writes pages to the local database. Here we validate and return the results for the caller to apply.

Errors

Returns error if not in APPLYING state.

pub fn reset_to_listening(&mut self) -> Result<()>

Transition from COMPLETE back to LISTENING for the next changeset.

Errors

Returns error if not in COMPLETE state.

pub fn force_reset(&mut self)

Force reset to LISTENING from any state (e.g., on error recovery).

Trait Implementations

impl Debug for ReplicationReceiver

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

Formats the value using the given formatter.

impl Default for ReplicationReceiver

fn default() -> Self

Returns the “default value” for a type.