Struct DistributedStateStore 

pub struct DistributedStateStore { /* private fields */ }

Distributed state store with consistent FNV-1a hashing for key-to-partition mapping.

Each key is routed to exactly one partition. Replication is handled by replicate_to which returns a snapshot of a partition for a peer node.

Implementations

impl DistributedStateStore

pub fn new(partition_count: u32, replication_factor: usize) -> Self

Create a new store with partition_count partitions.

pub fn partition_for(&self, key: &str) -> u32

Determine which partition a key belongs to (consistent hashing).

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

Get a value by key, or None if absent.

pub fn set(&mut self, key: &str, value: PartitionStateValue) -> u64

Set a key-value pair. Returns the new partition version number.

pub fn delete(&mut self, key: &str) -> bool

Delete a key. Returns true if the key previously existed.

pub fn replicate_to( &self, _peer: &str, partition_id: u32, ) -> Vec<(String, PartitionStateValue)>

Return all key-value pairs from partition_id for replication to peer.

pub fn checkpoint_partition(&mut self, partition_id: u32) -> StatePartition

Snapshot a partition (clone it) and record last_checkpointed timestamp.

pub fn restore_partition(&mut self, partition: StatePartition)

Restore a partition from a previously-created checkpoint snapshot.

pub fn partition_count(&self) -> u32

Total number of partitions in this store.

pub fn total_keys(&self) -> usize

Total number of keys across all partitions.

pub fn replication_factor(&self) -> usize

The configured replication factor.

pub fn coordinator(&self) -> &StateCoordinator

Read-only reference to the coordinator.

pub fn coordinator_mut(&mut self) -> &mut StateCoordinator

Mutable reference to the coordinator.