Struct ReplicatorActor 

pub struct ReplicatorActor { /* private fields */ }

Actor-style replicator handle.

Implementations

impl ReplicatorActor

pub fn spawn() -> Self

Spawn a new replicator with the default in-memory store.

pub fn spawn_with(store: Arc<dyn DurableStore>) -> Self

Spawn a new replicator with a pluggable durable backend.

pub fn inner(&self) -> &Arc<Replicator>

Read-only access to the inner replicator (subscriptions etc).

pub async fn update<T>( &self, key: impl Into<String>, value: T, _write: WriteConsistency, ) -> ReplicatorAck

where T: CrdtMerge + Send + Sync + 'static,

Submit a typed update and wait for the ack.

pub async fn get<T>( &self, key: impl Into<String>, _read: ReadConsistency, ) -> Option<T>

where T: CrdtMerge + Clone + Send + Sync + 'static,

Read a key. Consistency is Local for now (Phase 8.D wires the quorum exchange once gossip lands).

pub async fn delete(&self, key: impl Into<String>) -> ReplicatorAck

Delete a key.

pub async fn shutdown(self)

Stop the actor task and join it.

Trait Implementations

impl Drop for ReplicatorActor

fn drop(&mut self)

Executes the destructor for this type.