Struct RiMemoryQueue 

pub struct RiMemoryQueue { /* private fields */ }

In-memory queue implementation.

This struct implements the RiQueue trait for an in-memory queue backend. It supports optional disk persistence for message durability.

Implementations

impl RiMemoryQueue

pub fn new(name: &str) -> Self

Creates a new in-memory queue without persistence.

Parameters

• name: The name of the queue

Returns

A new RiMemoryQueue instance

pub fn with_persistence(name: &str, persistence_path: &str) -> Self

Creates a new in-memory queue with disk persistence.

Parameters

• name: The name of the queue
• persistence_path: Path to the file where messages will be persisted

Returns

A new RiMemoryQueue instance with persistence enabled

Trait Implementations

impl RiQueue for RiMemoryQueue

fn create_producer<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RiResult<Box<dyn RiQueueProducer>>> + Send + 'async_trait>>

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

Creates a new producer for this queue.

Returns

A RiResult<Box<dyn RiQueueProducer>> containing the producer

fn create_consumer<'life0, 'life1, 'async_trait>( &'life0 self, consumer_group: &'life1 str, ) -> Pin<Box<dyn Future<Output = RiResult<Box<dyn RiQueueConsumer>>> + Send + 'async_trait>>

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

Creates a new consumer for this queue with the given consumer group.

Parameters

• consumer_group: The name of the consumer group

Returns

A RiResult<Box<dyn RiQueueConsumer>> containing the consumer

fn get_stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RiResult<RiQueueStats>> + Send + 'async_trait>>

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

Gets statistics for this queue.

Returns

A RiResult<RiQueueStats> containing the queue statistics

fn purge<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

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

Purges all messages from this queue.

Returns

A RiResult<()> indicating success or failure

fn delete<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

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

Deletes this queue.

Returns

A RiResult<()> indicating success or failure