reliar-outbox 0.7.0

Storage-agnostic transactional outbox: OutboxStore/Publisher contracts, retry policy, settings and dispatcher (no storage or transport dependency).
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

//! `serde` (de)serialization for [`std::time::Duration`] as integer milliseconds, matching the
//! `*_ms` environment variables `from_env` reads. Only compiled behind the `serde` feature.

#![cfg(feature = "serde")]

/// `#[serde(with = "duration_serde::millis")]` on a required `Duration` field.
pub(crate) mod millis {
    use std::time::Duration;

    use serde::{Deserialize, Deserializer, Serializer, ser::Error as _};

    pub(crate) fn serialize<S: Serializer>(value: &Duration, s: S) -> Result<S::Ok, S::Error> {
        let ms = u64::try_from(value.as_millis()).map_err(S::Error::custom)?;

        s.serialize_u64(ms)
    }

    pub(crate) fn deserialize<'de, D: Deserializer<'de>>(d: D) -> Result<Duration, D::Error> {
        Ok(Duration::from_millis(u64::deserialize(d)?))
    }
}

/// `#[serde(with = "duration_serde::optional_millis")]` on an `Option<Duration>` field.
pub(crate) mod optional_millis {
    use std::time::Duration;

    use serde::{Deserialize, Deserializer, Serialize, Serializer, ser::Error as _};

    #[allow(
        clippy::ref_option,
        reason = "serde's `with` derive calls this as `&self.field`; the field is `Option<Duration>`"
    )]
    pub(crate) fn serialize<S: Serializer>(
        value: &Option<Duration>,
        s: S,
    ) -> Result<S::Ok, S::Error> {
        match value {
            Some(value) => {
                let ms = u64::try_from(value.as_millis()).map_err(S::Error::custom)?;

                Some(ms).serialize(s)
            }
            None => None::<u64>.serialize(s),
        }
    }

    pub(crate) fn deserialize<'de, D: Deserializer<'de>>(
        d: D,
    ) -> Result<Option<Duration>, D::Error> {
        Ok(Option::<u64>::deserialize(d)?.map(Duration::from_millis))
    }
}