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

//! Defines custom `DateTime` type.

use std::fmt;

use redis::{self, FromRedisValue, RedisResult, RedisWrite, ToRedisArgs};
use serde::Serialize;

/// Thin wrapper around a `chrono::DateTime<Utc>` with functions for custom (de)serialisation.
#[derive(Clone, Debug, PartialEq, PartialOrd, Serialize)]
pub struct DateTime(chrono::DateTime<chrono::Utc>);

impl DateTime {
    /// Get current UTC date/time.
    pub fn now() -> Self {
        DateTime(chrono::Utc::now())
    }

    /// Get number of seconds since another given date/time.
    pub fn seconds_since(&self, other: &DateTime) -> i64 {
        self.0.signed_duration_since(other.0).num_seconds()
    }
}

impl FromRedisValue for DateTime {
    ///  Parse an RFC3339 date string from Redis.
    fn from_redis_value(v: &redis::Value) -> RedisResult<Self> {
        let dt: String = redis::from_redis_value(v)?;
        Ok(DateTime(
            chrono::DateTime::parse_from_rfc3339(&dt)
                .unwrap()
                .with_timezone(&chrono::Utc),
        ))
    }
}

impl ToRedisArgs for DateTime {
    /// Format this struct as an RFC3339 date string for storage in Redis.
    fn write_redis_args<W: ?Sized + RedisWrite>(&self, out: &mut W) {
        self.0.to_rfc3339().write_redis_args(out)
    }
}

impl fmt::Display for DateTime {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        write!(f, "{}", self.0.to_rfc3339())
    }
}