sova-store 0.1.6

KvStore trait + memory / file / sql / redis / redb backends for Sova
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

//! MemoryStore put / get / ttl.

use bytes::Bytes;
use sova_store::{KvStore, MemoryStore};
use std::time::Duration;

#[tokio::test]
async fn put_get() {
    let store = MemoryStore::new();
    store
        .set("k", Bytes::from_static(b"v"), None)
        .await;
    assert_eq!(store.get("k").await.as_deref(), Some(b"v".as_slice()));
    store.remove("k").await;
    assert!(store.get("k").await.is_none());
}

#[tokio::test]
async fn ttl_expires() {
    let store = MemoryStore::new();
    store
        .set("t", Bytes::from_static(b"1"), Some(Duration::from_millis(40)))
        .await;
    assert_eq!(store.get("t").await.as_deref(), Some(b"1".as_slice()));
    tokio::time::sleep(Duration::from_millis(70)).await;
    assert!(store.get("t").await.is_none());
}

#[tokio::test]
async fn app_store_memory_put_get() {
    use sova_store::AppStore;
    let app_store = AppStore::memory();
    app_store
        .inner
        .set("a", Bytes::from_static(b"b"), None)
        .await;
    assert_eq!(
        app_store.inner.get("a").await.as_deref(),
        Some(b"b".as_slice())
    );
}