aj_core 0.8.0

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

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

#[derive(Debug)]
pub enum Error {
    #[cfg(feature = "redis")]
    Redis(RedisError),
    CronError(cron::error::Error),
    ActorError(String),
    NoQueueRegister,
    SerializeError,
}

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