Struct generic_db_observer::redis::Redis

pub struct Redis {
    pub connection: RedisConnection,
    pub config: RedisConfig,
}

The main Redis message broker structure.

Fields

connection: RedisConnection

Connection to the Redis Database.

config: RedisConfig

Configuration to authorize and reach the Redis data.

Implementations

impl Redis

pub fn del(&mut self, key: &str) -> RedisResult<()>

Deletes a key from Redis.

pub fn sadd<S: ToRedisArgs, T: ToRedisArgs>( &mut self, key: S, member: T ) -> RedisResult<()>

Adds a member to a set.

pub fn srem<S: ToRedisArgs, T: ToRedisArgs>( &mut self, key: S, member: T ) -> RedisResult<()>

Removes a member from a set

Trait Implementations

impl Debug for Redis

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

Formats the value using the given formatter.

impl MsgListener for Redis

async fn subscribe_to_notifications(&mut self) -> Result<(), Self::Error>

Subscribe to the appropriate Redis PubSub channel.

async fn notification_stream(&mut self) -> Option<Msg>

This function subscribes to the appropriate PubSub channel and then waits until

async fn get_current_state( &mut self ) -> Result<HashSet<String>, <Self as MsgListener>::Error>

Get all members of the referenced Redis set.

type Config = RedisConfig

Configuration for connecting to the message broker system.

type Connection = RedisConnection

Connection interface for the message broker.

type Message = Msg

Message type received through the broker.

type Error = RedisError

Any Error type returned by operations on the message broker.

async fn connect(config: &Self::Config) -> Result<Self, Self::Error>

Establishes connection to the message broker using the provided configuration.