Struct RedisClient

pub struct RedisClient { /* private fields */ }

Implementations

impl RedisClient

pub async fn new() -> Result<RedisClient>

Examples found in repository

examples/consume.rs (line 13)

async fn main() -> Result<()> {
    let redis = RedisClient::new().await?;
    let mut queue = Queue::new(redis, 10);

    let _t2 = tokio::spawn({
        let mut q = queue.clone();

        async move {
            let mut i: i32 = 0;
            loop {
                let job = Job { id: format!("{i}") };
                i += 1;

                q.publish(&job).await.unwrap();
                sleep(Duration::from_millis(5)).await;
            }
        }
    });

    let consumers: Vec<_> = (1..50)
        .into_iter()
        .map(|i| {
            let mut consumer = queue.new_consumer();

            tokio::spawn({
                async move {
                    loop {
                        let job = consumer.fetch_task().await;
                        println!("consumer_id: {}, consumed job {:?}", i, job)
                    }
                }
            })
        })
        .collect();

    queue.start().await?;
    try_join_all(consumers).await?;

    Ok(())
}

pub async fn rpop(&mut self, count: i32) -> Result<Vec<Job>>

pub async fn lpush(&mut self, job: &Job) -> Result<()>

pub async fn rpoplpush(&mut self) -> Result<Option<Job>>

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.