quick-kv 1.0.0

A reliable key-value storage for modern software
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

use std::fmt::Debug;
use std::hash::Hash;

use chrono::{DateTime, Utc};
use serde::de::DeserializeOwned;
use serde::{Deserialize, Deserializer, Serialize};

/// Entry in the key-value store
#[derive(Debug, Serialize, Clone)]
pub(crate) struct Entry<T>
where
    T: Serialize + DeserializeOwned + Debug + Eq + PartialEq + Hash + Send + Sync,
{
    pub(crate) key: String,
    /// Stored data
    pub(crate) data: T,
    /// Instant at which the entry expires and should be removed from the
    /// database.
    pub(crate) expires_at: Option<DateTime<Utc>>,
}

impl<T> Entry<T>
where
    T: Serialize + DeserializeOwned + Debug + Eq + PartialEq + Hash + Send + Sync,
{
    pub(crate) fn new(key: String, data: T, expires_at: Option<DateTime<Utc>>) -> Self
    {
        Self { key, data, expires_at }
    }
}

impl<'de, T> Deserialize<'de> for Entry<T>
where
    T: Serialize + DeserializeOwned + Debug + Eq + PartialEq + Hash + Send + Sync,
{
    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
    where
        D: Deserializer<'de>,
    {
        #[derive(Deserialize)]
        struct EntryHelper<T>
        {
            key: String,
            data: T,
            expires_at: Option<DateTime<Utc>>,
        }

        let helper = EntryHelper::<T>::deserialize(deserializer)?;

        Ok(Self {
            key: helper.key,
            data: helper.data,
            expires_at: helper.expires_at,
        })
    }
}