Struct ReplicatorHandle 

pub struct ReplicatorHandle { /* private fields */ }

Handle returned by the user to the runtime at Open. The runtime uses this to drive replicator lifecycle via control events. Contains shared PartitionState for synchronous access-status fencing.

Implementations

impl ReplicatorHandle

pub fn new( control_tx: Sender<ReplicatorControlEvent>, state: Arc<PartitionState>, data_address: String, shutdown: CancellationToken, ) -> Self

pub async fn send_control<T>( &self, make: impl FnOnce(Sender<Result<T>>) -> ReplicatorControlEvent, timeout: Duration, ) -> Result<T>

Send a control event and wait for reply.

pub fn state(&self) -> &Arc<PartitionState>

Synchronous access to partition state (atomics, no channel hop).

pub fn data_address(&self) -> &str

Data plane address for operator registration.

pub fn abort(&self)

Cancel the replicator’s shutdown token for immediate abort.