Struct SecondaryReceiver 

pub struct SecondaryReceiver { /* private fields */ }

Secondary-side data server. Runs as a gRPC server on the data plane.

Handles:

• ReplicationStream: incremental replication from primary
• GetCopyContext: returns secondary’s state context during build
• CopyStream: receives full state from primary during build

Implementations

impl SecondaryReceiver

pub fn new(state: Arc<SecondaryState>) -> Self

Create in volatile mode (auto-ACK, backward compatible with tests).

pub fn with_streams( state: Arc<SecondaryState>, partition_state: Arc<PartitionState>, operation_tx: Sender<Operation>, copy_stream_tx: Sender<Operation>, state_provider_tx: UnboundedSender<StateProviderEvent>, ) -> Self

Create in persisted mode with full copy support.

Trait Implementations

impl ReplicatorData for SecondaryReceiver

type ReplicationStreamStream = ReceiverStream<Result<ReplicationAck, Status>>

Server streaming response type for the ReplicationStream method.

fn replication_stream<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<ReplicationItem>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::ReplicationStreamStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Incremental replication: primary streams ops, secondary ACKs

fn get_copy_context<'life0, 'async_trait>( &'life0 self, _request: Request<GetCopyContextRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetCopyContextResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Copy protocol: primary ↔ secondary during BuildReplica

fn copy_stream<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<CopyItem>>, ) -> Pin<Box<dyn Future<Output = Result<Response<CopyStreamResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Primary streams full state to secondary