alopex-core 0.8.6

Core storage engine for Alopex DB - LSM-tree, columnar storage, and vector index
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

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

use alopex_core::kv::async_adapter::AsyncKVStoreAdapter;
use alopex_core::kv::memory::MemoryKV;
use alopex_core::kv::{AsyncKVStore, AsyncKVTransaction};
use futures::StreamExt;

#[cfg_attr(not(feature = "lane_ci"), ignore)]
#[tokio::test]
async fn async_kv_put_get_scan_commit() {
    let store = MemoryKV::new();
    let async_store = AsyncKVStoreAdapter::new(store);

    let mut txn = async_store.begin_async().await.expect("begin");
    txn.async_put(b"user:1", b"alice").await.expect("put");
    txn.async_put(b"user:2", b"bob").await.expect("put");
    txn.async_put(b"order:1", b"42").await.expect("put");

    let value = txn.async_get(b"user:1").await.expect("get");
    assert_eq!(value.as_deref(), Some(b"alice".as_ref()));

    let mut stream = txn.async_scan_prefix(b"user:");
    let mut keys = Vec::new();
    while let Some(entry) = stream.next().await {
        let (key, _) = entry.expect("scan");
        keys.push(String::from_utf8(key).expect("utf8"));
    }
    keys.sort();
    assert_eq!(keys, vec!["user:1".to_string(), "user:2".to_string()]);
    drop(stream);

    txn.async_commit().await.expect("commit");

    let txn = async_store.begin_async().await.expect("begin");
    let value = txn.async_get(b"user:2").await.expect("get");
    assert_eq!(value.as_deref(), Some(b"bob".as_ref()));
    txn.async_rollback().await.expect("rollback");
}

#[cfg_attr(not(feature = "lane_ci"), ignore)]
#[tokio::test]
async fn async_kv_rollback_discards_changes() {
    let store = MemoryKV::new();
    let async_store = AsyncKVStoreAdapter::new(store);

    let mut txn = async_store.begin_async().await.expect("begin");
    txn.async_put(b"temp:1", b"shadow").await.expect("put");
    txn.async_rollback().await.expect("rollback");

    let txn = async_store.begin_async().await.expect("begin");
    let value = txn.async_get(b"temp:1").await.expect("get");
    assert!(value.is_none());
    txn.async_rollback().await.expect("rollback");
}