Struct MemoryStore 

pub struct MemoryStore { /* private fields */ }

A FIFO data store that keeps items in memory.

Items are stored until fetched or until max_items is reached, at which point older items are removed to make space for new ones. The store maintains data in a queue structure and supports concurrent access.

When items are fetched, they are packaged into a JSON batch with metadata including:

• A batch array containing the items
• A timestamp indicating when the batch was created
• The store’s write key

Implementations

impl MemoryStore

pub fn new(config: MemoryConfig) -> Self

Creates a new MemoryStore with the specified configuration.

Panics

• If max_fetch_size is less than 100 bytes
• If max_items is 0

Trait Implementations

impl DataStore for MemoryStore

type Output = Value

The type of data returned by fetch operations.

fn has_data(&self) -> bool

Checks if the store contains any data that can be fetched.

fn reset(&mut self)

Removes all data from the store and resets it to initial state.

fn append(&mut self, data: Value) -> Result<()>

Appends a new item to the store.

fn fetch( &mut self, count: Option<usize>, max_bytes: Option<usize>, ) -> Result<Option<DataResult<Self::Output>>>

Fetches a batch of data from the store, respecting optional count and size limits.

fn remove(&mut self, data: &[Box<dyn Equivalent>]) -> Result<()>

Removes previously fetched data from the store.