Struct InMemoryStorage 

pub struct InMemoryStorage { /* private fields */ }

In-memory storage implementation

Thread-safe storage with:

• RwLock<HashMap> for stream lookup (concurrent reads)
• Per-stream RwLock for exclusive write access (offset monotonicity)
• Memory limit enforcement (global and per-stream)

Concurrency Model

Multiple readers can access different streams concurrently. Appends to the same stream are serialized via RwLock::write(). Appends to different streams can proceed concurrently.

Implementations

impl InMemoryStorage

pub fn new(max_total_bytes: u64, max_stream_bytes: u64) -> Self

Create a new in-memory storage with memory limits

pub fn total_bytes(&self) -> u64

Get current total memory usage

Panics

Panics if the total_bytes lock is poisoned (which indicates a panic while holding the lock).

Trait Implementations

impl Storage for InMemoryStorage

fn create_stream( &self, name: &str, config: StreamConfig, ) -> Result<CreateStreamResult>

Create a new stream

fn append(&self, name: &str, data: Bytes, content_type: &str) -> Result<Offset>

Append data to a stream

fn batch_append( &self, name: &str, messages: Vec<Bytes>, content_type: &str, seq: Option<&str>, ) -> Result<Offset>

Append multiple messages atomically

fn read(&self, name: &str, from_offset: &Offset) -> Result<ReadResult>

Read messages from a stream starting at offset

fn delete(&self, name: &str) -> Result<()>

Delete a stream

fn head(&self, name: &str) -> Result<StreamMetadata>

Get stream metadata

fn close_stream(&self, name: &str) -> Result<()>

Close a stream

fn append_with_producer( &self, name: &str, messages: Vec<Bytes>, content_type: &str, producer: &ProducerHeaders, should_close: bool, seq: Option<&str>, ) -> Result<ProducerAppendResult>

Append messages with producer sequencing (atomic validation + append)

fn create_stream_with_data( &self, name: &str, config: StreamConfig, messages: Vec<Bytes>, should_close: bool, ) -> Result<CreateWithDataResult>

Atomically create a stream with optional initial data and close.

fn exists(&self, name: &str) -> bool

Check if a stream exists

fn subscribe(&self, name: &str) -> Option<Receiver<()>>

Subscribe to notifications for new data on a stream.