Struct ReplicatedEmbeddedStore 

pub struct ReplicatedEmbeddedStore { /* private fields */ }

Implementations

impl ReplicatedEmbeddedStore

pub fn new(shard_count: usize, config: ReplicationConfig) -> Result<Self>

pub fn with_route_mode( shard_count: usize, route_mode: EmbeddedRouteMode, config: ReplicationConfig, ) -> Result<Self>

pub fn get(&self, key: &[u8]) -> Option<Bytes>

pub fn set(&self, key: Bytes, value: Bytes, ttl_ms: Option<u64>)

pub fn delete(&self, key: &[u8]) -> bool

pub fn expire(&self, key: &[u8], expire_at_ms: u64) -> bool

pub fn snapshot(&self) -> ReplicationSnapshot

Captures a consistent snapshot for replica bootstrap.

Watermarks are taken first so any mutation that lands between the watermark read and the entry read is reflected in the entries. Catch-up from this watermark may re-deliver those mutations, but apply_mutation deduplicates by sequence so re-delivery is a no-op.

pub fn catch_up_replica(&self, replica: &mut ReplicationReplica) -> Result<()>

pub fn primary(&self) -> Arc<ReplicationPrimary>

pub fn metrics_snapshot(&self) -> ReplicationMetricsSnapshot

pub fn inner(&self) -> &EmbeddedStore

Trait Implementations

impl Debug for ReplicatedEmbeddedStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for ReplicatedEmbeddedStore

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl SnapshotProvider for ReplicatedEmbeddedStore

fn snapshot(&self) -> ReplicationSnapshot

Returns a consistent snapshot together with the watermarks captured at the same logical point.