Struct ReplicationQueue 

pub struct ReplicationQueue { /* private fields */ }

In-memory replication queue. Retains ops from first_lsn to highest_lsn. Ops are GC’d when all configured secondaries have ACKed them.

This serves the same role as SF’s ReplicationQueueManager — it bridges the gap between the copy stream (committed state) and live replication (new ops) by retaining in-flight ops that can be replayed to new replicas.

Implementations

impl ReplicationQueue

pub fn new() -> Self

pub fn push(&mut self, lsn: Lsn, data: Bytes)

Append a new op. Called from the data path on every replicate.

pub fn ops_from(&self, from_lsn: Lsn) -> Vec<(Lsn, Bytes)>

Get all ops from from_lsn onward (inclusive). Used at add_secondary time to replay pending ops to a new replica.

pub fn gc(&mut self, acked_lsn: Lsn)

Remove all ops with LSN <= acked_lsn. Called when the minimum ACKed LSN across all secondaries advances.

pub fn len(&self) -> usize

Number of ops retained in the queue.

pub fn is_empty(&self) -> bool

pub fn clear(&mut self)

Clear all ops (on role change / close).

Trait Implementations

impl Default for ReplicationQueue

fn default() -> Self

Returns the “default value” for a type.