Struct sea_streamer_redis::RedisStreamer

pub struct RedisStreamer { /* private fields */ }

The Redis Streamer, from which you can create Producers and Consumers.

Trait Implementations

impl Clone for RedisStreamer

fn clone(&self) -> RedisStreamer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RedisStreamer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Streamer for RedisStreamer

type Error = RedisErr

type Producer = RedisProducer

type Consumer = RedisConsumer

type ConnectOptions = RedisConnectOptions

type ConsumerOptions = RedisConsumerOptions

type ProducerOptions = RedisProducerOptions

async fn connect( uri: StreamerUri, options: Self::ConnectOptions ) -> RedisResult<Self>

Establish a connection to the streaming server.

async fn disconnect(self) -> RedisResult<()>

Flush and disconnect from the streaming server.

async fn create_generic_producer( &self, options: Self::ProducerOptions ) -> RedisResult<Self::Producer>

Create a producer that can stream to any stream key.

async fn create_consumer( &self, streams: &[StreamKey], options: Self::ConsumerOptions ) -> RedisResult<Self::Consumer>

Create a consumer subscribing to the specified streams.

fn create_producer( &self, stream: StreamKey, options: Self::ProducerOptions ) -> impl Future<Output = Result<Self::Producer, StreamErr<Self::Error>>> + Send

Create a producer that streams to the specified stream.