Struct Replicator 

pub struct Replicator { /* private fields */ }

Implementations

impl Replicator

pub fn new() -> Arc<Self>

pub fn update<T>(&self, key: &str, value: T)

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

pub fn subscribe<F>( self: &Arc<Self>, key: impl Into<String>, notifier: F, ) -> SubscriptionToken

where F: Fn(&str) + Send + Sync + 'static,

Register notifier to fire on every successful update(key, _) or delete(key). Returns a SubscriptionToken whose Drop removes the subscription. Phase 8.E.

pub fn notify(&self, key: &str)

Internal: deliver notifications. Public so the cluster adapter can re-fire after a remote merge.

pub fn subscriber_count(&self, key: &str) -> usize

Number of subscribers for a key (debug / telemetry).

pub fn get<T>(&self, key: &str) -> Option<T>

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

pub fn delete(&self, key: &str)

pub fn keys(&self) -> Vec<String>

Snapshot of all keys currently held by this replicator. Useful for telemetry / dashboards.

Trait Implementations

impl Default for Replicator

fn default() -> Self

Returns the “default value” for a type.