aj_core 0.9.1

Background Job Library for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

#[cfg(feature = "redis")]
use redis::RedisError;

#[derive(Debug)]
pub enum Error {
    #[cfg(feature = "redis")]
    Redis(RedisError),
    /// Postgres backend failure. Carries the formatted error rather than the concrete type,
    /// because the driver, the pool and pool construction each have their own error type and
    /// they all need to land in one variant.
    #[cfg(feature = "postgres")]
    Postgres(String),
    CronError(cron::error::Error),
    ActorError(String),
    NoQueueRegister,
    SerializeError,
}

#[cfg(feature = "redis")]
impl From<RedisError> for Error {
    fn from(value: RedisError) -> Self {
        Self::Redis(value)
    }
}

#[cfg(feature = "postgres")]
impl From<deadpool_postgres::tokio_postgres::Error> for Error {
    fn from(value: deadpool_postgres::tokio_postgres::Error) -> Self {
        Self::Postgres(format!("{value}"))
    }
}

#[cfg(feature = "postgres")]
impl From<deadpool_postgres::PoolError> for Error {
    fn from(value: deadpool_postgres::PoolError) -> Self {
        Self::Postgres(format!("{value}"))
    }
}

#[cfg(feature = "postgres")]
impl From<deadpool_postgres::CreatePoolError> for Error {
    fn from(value: deadpool_postgres::CreatePoolError) -> Self {
        Self::Postgres(format!("{value}"))
    }
}

impl From<cron::error::Error> for Error {
    fn from(value: cron::error::Error) -> Self {
        Self::CronError(value)
    }
}

impl<M, E: std::fmt::Debug> From<kameo::error::SendError<M, E>> for Error {
    fn from(value: kameo::error::SendError<M, E>) -> Self {
        Self::ActorError(format!("{:?}", value))
    }
}