Struct MemoryStorage 

pub struct MemoryStorage { /* private fields */ }

Pure in-memory storage backend.

See module docs for the detailed semantic contract. Safe to share across threads as Send + Sync; internal state is behind &mut self so callers wrap it in their own synchronisation (as KimberliteInner does via its outer RwLock).

Implementations

impl MemoryStorage

pub fn new() -> Self

Creates a new empty in-memory storage with default segment size.

pub fn with_max_segment_size(max_segment_size: u64) -> Self

Creates a new empty in-memory storage with a custom notional segment size. Intended for tests that want to exercise the rotation bookkeeping without writing 256 MB of data.

pub fn max_segment_size(&self) -> u64

Returns the configured notional segment size in bytes.

Trait Implementations

impl Debug for MemoryStorage

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

Formats the value using the given formatter.

impl Default for MemoryStorage

fn default() -> Self

Returns the “default value” for a type.

impl StorageBackend for MemoryStorage

fn append_batch( &mut self, stream_id: StreamId, events: Vec<Bytes>, expected_offset: Offset, prev_hash: Option<ChainHash>, _fsync: bool, ) -> Result<(Offset, ChainHash), StorageError>

Appends a batch of events to a stream and extends the hash chain.

fn read_from( &mut self, stream_id: StreamId, from_offset: Offset, max_bytes: u64, ) -> Result<Vec<Bytes>, StorageError>

Reads events from a stream with checkpoint-optimised chain verification.

fn latest_chain_hash( &mut self, stream_id: StreamId, ) -> Result<Option<ChainHash>, StorageError>

Returns the chain hash of the last appended record for the stream, or None if the stream has never been written to.

fn segment_count(&self, stream_id: StreamId) -> usize

Number of segments (active + completed) for a stream.

fn completed_segments(&self, stream_id: StreamId) -> Vec<u32>

Numbers of the completed (immutable) segments for a stream.

fn flush_indexes(&mut self) -> Result<(), StorageError>

Best-effort flush of any backend-internal buffers.