Struct QueueStore 

pub struct QueueStore<T> { /* private fields */ }

A store that uses the filesystem to persist events in a queue

Implementations

impl<T: Serialize + DeserializeOwned + Send + Sync> QueueStore<T>

pub fn new(directory: impl Into<PathBuf>, limit: u64, ext: &str) -> Self

Creates a new QueueStore

pub fn new_with_compression( directory: impl Into<PathBuf>, limit: u64, ext: &str, compress: bool, ) -> Self

Creates a new QueueStore with an explicit compression setting.

Trait Implementations

impl<T> Clone for QueueStore<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> FailedEventStore for QueueStore<T>

where T: Serialize + DeserializeOwned + Clone + Send + Sync + 'static,

fn put_failed_raw( &self, entry_name: &str, data: &[u8], ) -> Result<String, StoreError>

Writes pre-encoded bytes to the failed-events store under the given entry name and returns the written entry id.

fn prune_failed_store(&self) -> Result<usize, StoreError>

Removes failed-store entries older than the retention bound and returns how many were removed.

fn failed_len(&self) -> usize

Returns the number of entries currently in the failed store.

fn boxed_clone_failed(&self) -> Box<dyn FailedEventStore>

Clones the capability into an owned boxed handle sharing the same backing state, so the maintenance scan can run inside a blocking task without borrowing the target.

impl<T> Store<T> for QueueStore<T>

where T: Serialize + DeserializeOwned + Clone + Send + Sync + 'static,

type Error = StoreError

The error type for the store

type Key = Key

The key type for the store

fn open(&self) -> Result<(), Self::Error>

Opens the store

fn put(&self, item: Arc<T>) -> Result<Self::Key, Self::Error>

Stores a single item

fn put_multiple(&self, items: Vec<T>) -> Result<Self::Key, Self::Error>

Stores multiple items in a single batch

fn put_raw(&self, data: &[u8]) -> Result<Self::Key, Self::Error>

Stores raw bytes in a single entry.

fn get(&self, key: &Self::Key) -> Result<T, Self::Error>

Retrieves a single item by key

fn get_multiple(&self, key: &Self::Key) -> Result<Vec<T>, Self::Error>

Retrieves multiple items by key

fn get_raw(&self, key: &Self::Key) -> Result<Vec<u8>, Self::Error>

Retrieves the raw bytes stored for a key.

fn del(&self, key: &Self::Key) -> Result<(), Self::Error>

Deletes an item by key

fn delete(&self) -> Result<(), Self::Error>

Deletes the underlying store directory and clears all in-memory state.

fn list(&self) -> Vec<Self::Key>

Lists all keys in the store

fn len(&self) -> usize

Returns the number of items in the store

fn is_empty(&self) -> bool

Returns true if the store is empty

fn boxed_clone( &self, ) -> Box<dyn Store<T, Error = Self::Error, Key = Self::Key> + Send + Sync>

Clones the store into a boxed trait object