Struct InMemoryFrameStore 

pub struct InMemoryFrameStore { /* private fields */ }

Lock-free in-memory FrameStoreGat implementation.

Frames are stored per stream in a VecDeque in append order. Lookups scan the per-stream deque under a single shard lock, so cost grows linearly with frame history depth — fine for the bounded sizes we cap at.

Implementations

impl InMemoryFrameStore

pub fn new() -> Self

Create a store with the default per-stream cap (DEFAULT_FRAME_HISTORY_PER_STREAM).

pub fn with_capacity(max_frames_per_stream: usize) -> Self

Create a store with an explicit per-stream cap.

max_frames_per_stream must be at least 1 — a zero cap would drop every frame on insertion and is rejected via debug assertion (the constructor silently substitutes 1 in release builds).

pub fn stream_count(&self) -> usize

Number of streams that currently have frame history.

Trait Implementations

impl Debug for InMemoryFrameStore

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

Formats the value using the given formatter.

impl Default for InMemoryFrameStore

fn default() -> Self

Returns the “default value” for a type.

impl FrameStoreGat for InMemoryFrameStore

type AppendFramesFuture<'a> = impl Future<Output = Result<(), DomainError>> + Send + 'a where Self: 'a

Append frames produced for stream_id. Frames are stored in append order (which equals sequence order, since frames are emitted with monotonically increasing sequence numbers).

type GetFramesFuture<'a> = impl Future<Output = Result<FrameStorePage, DomainError>> + Send + 'a where Self: 'a

Retrieve frames for stream_id honoring the optional filters.

type DeleteFramesForStreamFuture<'a> = impl Future<Output = Result<(), DomainError>> + Send + 'a where Self: 'a

Drop every frame stored for stream_id.

fn append_frames( &self, stream_id: StreamId, frames: Vec<Frame>, ) -> Self::AppendFramesFuture<'_>

Append frames produced for stream_id. Frames are stored in append order (which equals sequence order, since frames are emitted with monotonically increasing sequence numbers).

fn get_frames( &self, stream_id: StreamId, since_sequence: Option<u64>, priority_filter: Option<Priority>, limit: Option<usize>, ) -> Self::GetFramesFuture<'_>

Retrieve frames for stream_id honoring the optional filters.

fn delete_frames_for_stream( &self, stream_id: StreamId, ) -> Self::DeleteFramesForStreamFuture<'_>

Drop every frame stored for stream_id.