Struct InMemoryFrameRepository

pub struct InMemoryFrameRepository { /* private fields */ }

In-memory implementation of FrameRepository

Implementations

impl InMemoryFrameRepository

pub fn new() -> Self

Trait Implementations

impl Default for InMemoryFrameRepository

fn default() -> Self

Returns the “default value” for a type.

impl FrameRepository for InMemoryFrameRepository

fn store_frame<'life0, 'async_trait>( &'life0 self, frame: Frame, ) -> Pin<Box<dyn Future<Output = DomainResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Store frame with priority indexing

fn store_frames<'life0, 'async_trait>( &'life0 self, frames: Vec<Frame>, ) -> Pin<Box<dyn Future<Output = DomainResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Store multiple frames efficiently

fn get_frames_by_stream<'life0, 'async_trait>( &'life0 self, stream_id: StreamId, priority_filter: Option<Priority>, pagination: Pagination, ) -> Pin<Box<dyn Future<Output = DomainResult<FrameQueryResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get frames by stream with priority filtering

fn get_frames_by_path<'life0, 'async_trait>( &'life0 self, stream_id: StreamId, path: JsonPath, ) -> Pin<Box<dyn Future<Output = DomainResult<Vec<Frame>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get frames by JSON path

fn cleanup_old_frames<'life0, 'async_trait>( &'life0 self, older_than: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = DomainResult<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete frames older than specified time

fn get_frame_priority_distribution<'life0, 'async_trait>( &'life0 self, stream_id: StreamId, ) -> Pin<Box<dyn Future<Output = DomainResult<PriorityDistribution>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get frame count by priority distribution