Struct RedisStreams 

pub struct RedisStreams { /* private fields */ }

Redis Streams client for event-driven architectures

Implementations

impl RedisStreams

pub async fn new(redis_url: &str) -> Result<Self>

Create a new RedisStreams instance

Errors

Returns an error if the Redis connection fails.

Trait Implementations

impl Clone for RedisStreams

fn clone(&self) -> RedisStreams

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl StreamingBackend for RedisStreams

Implement StreamingBackend trait for RedisStreams

fn stream_add<'a>( &'a self, stream_key: &'a str, fields: Vec<(String, String)>, maxlen: Option<usize>, ) -> BoxFuture<'a, Result<String>>

Add an entry to a stream

fn stream_read_latest<'a>( &'a self, stream_key: &'a str, count: usize, ) -> BoxFuture<'a, Result<Vec<StreamEntry>>>

Read the latest N entries from a stream (newest first)

fn stream_read<'a>( &'a self, stream_key: &'a str, last_id: &'a str, count: usize, block_ms: Option<usize>, ) -> BoxFuture<'a, Result<Vec<StreamEntry>>>

Read entries from a stream with optional blocking