Struct SimStorage 

pub struct SimStorage { /* private fields */ }

Simulated persistent storage with WAL and fault injection.

BTreeMap-backed for deterministic iteration order.

Implementations

impl SimStorage

pub fn new(node_id: NodeId) -> Self

Create a new simulated storage for the given node.

pub fn with_disk_model(node_id: NodeId, disk_model: DiskModel) -> Self

Create with a custom disk model.

pub fn set_snapshot_failure(&mut self, fail: bool)

Set snapshot failure fault.

pub fn set_silent_corrupt_probability(&mut self, p: f64)

Set silent corruption probability.

pub fn set_faults(&mut self, faults: StorageFaultConfig)

Set fault configuration.

pub fn set_disk_full(&mut self, full: bool)

Enable disk full fault.

pub fn set_read_error(&mut self, err: bool)

Enable read error fault.

pub fn crash(&mut self)

Simulate a crash: lose unfsynced WAL entries, recover from fsynced.

pub fn crash_and_recover(&mut self, rng: &mut DetRng)

Simulate a crash and restart with optional write reordering.

pub fn wal(&self) -> &SimWal

Get the WAL.

pub fn node_id(&self) -> NodeId

Node this storage belongs to.

pub fn total_reads(&self) -> u64

Stats: total reads.

pub fn total_writes(&self) -> u64

Stats: total writes.

pub fn faults(&self) -> &StorageFaultConfig

Get fault configuration.

Trait Implementations

impl VortexStorage for SimStorage

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

Get the value for a key.

fn put(&mut self, key: &[u8], value: &[u8]) -> Result<()>

Put a key-value pair.

fn delete(&mut self, key: &[u8]) -> Result<()>

Delete a key.

fn scan(&self, start: &[u8], end: &[u8]) -> Result<Vec<(Vec<u8>, Vec<u8>)>>

Scan a range of keys [start, end).

fn write_batch(&mut self, ops: Vec<StorageOp>) -> Result<()>

Apply a batch of operations atomically.

fn flush(&mut self) -> Result<()>

Flush pending writes to durable storage.

fn snapshot(&self) -> Result<Vec<(Vec<u8>, Vec<u8>)>>

Create a point-in-time snapshot.