Struct PrimarySender 

pub struct PrimarySender { /* private fields */ }

Primary-side replication sender. Manages connections to all configured secondaries, sends operations, and routes ACKs back to the QuorumTracker.

Non-blocking design (matching SF): send_to_all enqueues ops into per-secondary unbounded channels and returns immediately. Each secondary has a background drain task that reads from the unbounded channel and writes to the gRPC stream. A slow secondary’s drain task blocks independently without affecting the actor or other secondaries.

Pending ops for new replicas are replayed from the ReplicationQueue at add_secondary time — no build buffers needed.

Implementations

impl PrimarySender

pub fn new(primary_id: ReplicaId, epoch: Epoch) -> Self

pub fn set_epoch(&mut self, epoch: Epoch)

pub async fn add_secondary( &mut self, replica_id: ReplicaId, address: String, quorum_tracker: Arc<Mutex<QuorumTracker>>, partition_state: Arc<PartitionState>, ) -> Result<()>

Connect to a secondary’s replication gRPC endpoint. If ops were buffered during build, they are replayed first.

Spawns two background tasks per secondary:

1. Drain task: reads from unbounded channel, writes to bounded gRPC stream. May block on slow secondary — only blocks this task.
2. ACK reader: reads ACKs from gRPC response stream, routes to QuorumTracker.

pub fn send_to_one( &self, replica_id: ReplicaId, lsn: Lsn, data: &Bytes, committed_lsn: Lsn, )

Send a single item to a specific secondary (for replay from queue).

pub fn remove_secondary(&mut self, replica_id: ReplicaId)

Remove a secondary connection.

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

Send an operation to all connected secondaries. Non-blocking — uses unbounded channels. Matches SF’s fire-and-forget dispatch.

pub fn connection_count(&self) -> usize

Number of connected secondaries.

pub fn has_connection(&self, replica_id: &ReplicaId) -> bool

Check if a secondary is connected.

pub fn connected_ids(&self) -> Vec<ReplicaId>

Get all connected replica IDs.

pub fn close_all(&mut self)

Close all connections.