Struct redis_cmd::cmd::RedisClient

pub struct RedisClient {
    pub client: ConnectionManager,
}

Fields

client: ConnectionManager

Implementations

impl RedisClient

pub async fn get<K: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K ) -> RedisResult<String>

pub async fn exists<K: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K ) -> RedisResult<u8>

pub async fn set<K: ToRedisArgs + Debug + Send + Sync, V: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K, value: V ) -> RedisResult<bool>

pub async fn expire<K: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K, expire: usize ) -> RedisResult<i8>

pub async fn del<K: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K ) -> RedisResult<u8>

pub async fn xadd<K: ToRedisArgs + Debug + Send + Sync, F: ToRedisArgs + Debug + Send + Sync, V: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K, items: &[(F, V)] ) -> RedisResult<String>

pub async fn xgroup_create<K: ToRedisArgs + Debug + Send + Sync, G: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K, group: G ) -> RedisResult<()>

return OK

pub async fn xread_group( &mut self, key: &str, group: &str, consumer: &str ) -> RedisResult<Value>

return OK

pub async fn xinfo_groups<K: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K ) -> RedisResult<Value>

pub async fn is_exist_group_name<K: ToRedisArgs + Debug + Send + Sync, G: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K, group: G ) -> RedisResult<bool>

pub async fn xinfo_consumers<K: ToRedisArgs + Debug + Send + Sync, G: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K, group: G ) -> RedisResult<Value>

pub async fn xclaim_auto<K: ToRedisArgs + Debug + Send + Sync, G: ToRedisArgs + Debug + Send + Sync, C: ToRedisArgs + Debug + Send + Sync, MIT: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K, group: G, consumer: C, min_idle_time: MIT ) -> RedisResult<Value>

pub async fn xpending_one<K: ToRedisArgs + Debug + Send + Sync, G: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K, group: G ) -> RedisResult<Value>

pub async fn get_id(&self, data: &Value) -> RedisResult<String>

pub async fn xack<K: ToRedisArgs + Debug + Send + Sync, G: ToRedisArgs + Debug + Send + Sync, I: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K, group: G, ids: &Vec<I> ) -> RedisResult<u64>

pub async fn xack2del<K: ToRedisArgs + Debug + Send + Sync, G: ToRedisArgs + Debug + Send + Sync, I: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K, group: G, ids: &Vec<I> ) -> RedisResult<(u64, u64)>

pub async fn xdel<K: ToRedisArgs + Debug + Send + Sync, I: ToRedisArgs + Debug + Send + Sync>( &mut self, key: K, ids: &Vec<I> ) -> RedisResult<u64>

Trait Implementations

impl Clone for RedisClient

fn clone(&self) -> RedisClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RedisClient

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

Formats the value using the given formatter.