ocypod 0.8.0

Ocypod is a Redis-backed service for orchestrating background jobs.
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

use redis::{self, from_redis_value, FromRedisValue, RedisResult};
use serde::{Deserialize, Serialize};

use crate::models::Duration;

#[derive(Clone, Debug, Deserialize, Serialize, PartialEq)]
#[serde(default)]
pub struct Settings {
    pub timeout: Duration,
    pub heartbeat_timeout: Duration,
    pub expires_after: Duration,
    pub retries: u64,
    pub retry_delays: Vec<Duration>,
}

impl FromRedisValue for Settings {
    fn from_redis_value(v: &redis::Value) -> RedisResult<Self> {
        let (timeout, heartbeat_timeout, expires_after, retries, retry_delays): (
            Duration,
            Duration,
            Duration,
            u64,
            Option<String>,
        ) = from_redis_value(v)?;
        let retry_delays = match retry_delays {
            Some(s) => serde_json::from_str(&s).unwrap(),
            None => Vec::new(),
        };
        Ok(Self {
            timeout,
            heartbeat_timeout,
            expires_after,
            retries,
            retry_delays,
        })
    }
}

impl Default for Settings {
    fn default() -> Self {
        Self {
            timeout: Duration::from_secs(300),
            heartbeat_timeout: Duration::from_secs(0),
            expires_after: Duration::from_secs(300),
            retries: 0,
            retry_delays: Vec::new(),
        }
    }
}