Struct sidekiq::RedisConnection

pub struct RedisConnection { /* private fields */ }

A wrapper type for making the redis crate compatible with namespacing.

Implementations

impl RedisConnection

pub fn new(connection: Connection) -> Self

pub fn set_namespace(&mut self, namespace: String)

pub fn with_namespace(self, namespace: String) -> Self

pub fn unnamespaced_borrow_mut(&mut self) -> &mut Connection

This allows you to borrow the raw redis connection without any namespacing support.

pub async fn brpop(
    &mut self,
    keys: Vec<String>,
    timeout: usize
) -> Result<Option<(String, String)>, Box<dyn Error>>

pub async fn del(&mut self, key: String) -> Result<usize, Box<dyn Error>>

pub async fn lpush(
    &mut self,
    key: String,
    value: String
) -> Result<(), Box<dyn Error>>

pub async fn zrange(
    &mut self,
    key: String,
    lower: isize,
    upper: isize
) -> Result<Vec<String>, Box<dyn Error>>

pub async fn zrangebyscore_limit<L: ToRedisArgs + Send + Sync, U: ToRedisArgs + Sync + Send>(
    &mut self,
    key: String,
    lower: L,
    upper: U,
    offset: isize,
    limit: isize
) -> Result<Vec<String>, Box<dyn Error>>

pub async fn zadd<V: ToRedisArgs + Send + Sync, S: ToRedisArgs + Send + Sync>(
    &mut self,
    key: String,
    value: V,
    score: S
) -> Result<usize, Box<dyn Error>>

pub async fn zadd_ch<V: ToRedisArgs + Send + Sync, S: ToRedisArgs + Send + Sync>(
    &mut self,
    key: String,
    value: V,
    score: S
) -> Result<bool, Box<dyn Error>>

pub async fn zrem(
    &mut self,
    key: String,
    value: String
) -> Result<bool, Box<dyn Error>>