Struct RiRedisQueue 

pub struct RiRedisQueue { /* private fields */ }

Redis queue implementation for the Ri queue system.

This struct provides a Redis implementation of the RiQueue trait, allowing sending and receiving messages using Redis lists as the underlying message broker.

Implementations

impl RiRedisQueue

pub async fn new(name: &str, connection_string: &str) -> RiResult<Self>

Creates a new Redis queue instance.

Parameters

• name: The name of the queue (Redis key)
• connection_string: The Redis connection string

Returns

A new RiRedisQueue instance wrapped in RiResult

pub fn new_with_client(name: &str, client: Client) -> RiResult<Self>

Creates a new Redis queue instance with an existing client.

Parameters

• name: The name of the queue (Redis key)
• client: The existing Redis client

Returns

A new RiRedisQueue instance wrapped in RiResult

pub async fn new_with_connection( name: &str, connection_string: &str, ) -> RiResult<Self>

Creates a new Redis queue instance with an existing connection.

Parameters

• name: The name of the queue (Redis key)
• connection_string: The Redis connection string

Returns

A new RiRedisQueue instance wrapped in RiResult

Trait Implementations

impl RiQueue for RiRedisQueue

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 the Redis queue.

Returns

A new RiQueueProducer instance wrapped in RiResult

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 the Redis queue.

Parameters

• _consumer_group: The consumer group name (ignored in this implementation)

Returns

A new RiQueueConsumer instance wrapped in RiResult

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 the Redis queue.

Returns

RiQueueStats containing queue statistics wrapped in RiResult

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 the Redis queue.

Returns

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 the Redis queue.

Note: This implementation simply calls purge since deleting a Redis key is the same as purging all messages from the queue.

Returns

RiResult indicating success or failure