Struct RocksStore 

pub struct RocksStore { /* private fields */ }

Minimal RocksDB-backed store for the simulator: batch writes plus a global sequence u64 plus a per-sequence batch log.

Implementations

impl RocksStore

pub fn open(path: &Path) -> Result<Self, Error>

pub fn open_with_observer( path: &Path, observer: Option<Arc<AtomicU64>>, ) -> Result<Self, Error>

Trait Implementations

impl Clone for RocksStore

fn clone(&self) -> RocksStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl StoreEngine for RocksStore

fn put_batch(&self, kvs: &[(Bytes, Bytes)]) -> Result<u64, String>

Persist key-value pairs atomically and return the new global sequence number for this write.

fn get(&self, key: &[u8]) -> Result<Option<Vec<u8>>, String>

Fetch the value for a single key. Returns None when the key does not exist.

fn range_scan( &self, start: &[u8], end: &[u8], limit: usize, forward: bool, ) -> Result<Vec<(Bytes, Bytes)>, String>

Keys in [start, end] (inclusive) when end is non-empty; empty end means unbounded above. Matches store.query.v1.RangeRequest / ReduceRequest on the wire. limit caps rows returned.

fn get_many( &self, keys: &[&[u8]], ) -> Result<Vec<(Vec<u8>, Option<Vec<u8>>)>, String>

Batch-get: returns (key, Option<value>) for each input key, preserving order.

fn delete_batch(&self, keys: &[&[u8]]) -> Result<u64, String>

Delete a batch of keys atomically. Returns the new global sequence number.

fn current_sequence(&self) -> u64

Current sequence number visible to readers (used for min_sequence_number checks).

fn get_batch( &self, sequence_number: u64, ) -> Result<Option<Vec<(Bytes, Bytes)>>, String>

Return the (key, value) pairs written by the put_batch call that was assigned sequence_number. Ok(None) = the batch has been pruned or was never written (the store.stream.v1 service maps None to NOT_FOUND with a BATCH_EVICTED detail).

fn oldest_retained_batch(&self) -> Result<Option<u64>, String>

Lowest retained batch sequence number, or None when the batch log is empty. Surfaced in BATCH_EVICTED error details so clients know where to resume from.

fn prune_batch_log(&self, cutoff_exclusive: u64) -> Result<u64, String>

Delete all batch-log entries with sequence_number < cutoff_exclusive. Returns the number of entries deleted. Invoked only by the compact service’s batch-log policy scope — never by ingest.