nest-rs-redis 0.5.0

Redis-backed queue integration for nest-rs-queue (via apalis-redis): the QueueConnection producer, the QueueWorker consumer transport, and the #[processor] decorator re-export. The user-facing storage is Redis; apalis is an implementation detail.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

//! Typed errors for the Redis queue backend.
//!
//! Framework crates surface `thiserror` enums, not `anyhow`. Opening the shared
//! connection is a Redis-specific step, so it carries its own error here; the
//! producer surface ([`Queue::push`](crate::Queue::push) and the `JobProducer`
//! impl) instead speaks the backend-agnostic
//! [`QueueError`](::nest_rs_queue::QueueError), wrapping a Redis push failure as
//! its opaque `Backend` source.

use thiserror::Error;

/// A failure opening the shared Redis
/// [`QueueConnection`](crate::QueueConnection) from the configured URL.
#[derive(Debug, Error)]
#[non_exhaustive]
pub enum ConnectionError {
    /// The Redis connection could not be established.
    #[error("failed to connect to Redis")]
    Connect(#[from] apalis_redis::RedisError),
}