Struct ReplicationSender 

pub struct ReplicationSender { /* private fields */ }

Replication sender state machine.

Implementations

impl ReplicationSender

pub fn new() -> Self

Create a new sender in IDLE state.

pub const fn state(&self) -> SenderState

Current state.

pub fn prepare( &mut self, page_size: u32, pages: &mut [PageEntry], config: SenderConfig, ) -> Result<()>

Transition from IDLE to ENCODING: prepare a changeset for streaming.

Errors

Returns error if not in IDLE state, pages are empty, or symbol size invalid.

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

Transition from ENCODING to STREAMING.

Errors

Returns error if not in ENCODING state.

pub fn next_packet(&mut self) -> Result<Option<ReplicationPacket>>

Generate the next replication packet in the stream.

Returns None when all shards have been fully streamed (ISI limit reached).

Errors

Returns error if not in STREAMING state.

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

Acknowledge completion from receiver: stop streaming and transition to COMPLETE.

Errors

Returns error if not in STREAMING state.

pub fn complete(&mut self)

Complete streaming: release resources and transition to COMPLETE.

This is called when ISI limit is reached or explicit stop.

pub fn reset(&mut self)

Reset to IDLE for the next replication session.

Trait Implementations

impl Debug for ReplicationSender

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

Formats the value using the given formatter.

impl Default for ReplicationSender

fn default() -> Self

Returns the “default value” for a type.