kmp-adapter-embedded 0.1.6

Embedded edition storage adapters: every KMP kernel port on a single local store file (redb by default, SQLite opt-in)
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

use kmp_domain::{NodeDetailProjection, NodeDetailReader, PortError};

use super::engine::{Key, Table};
use super::serdes::{DetailRecord, decode};
use super::store::EmbeddedKernelStore;

impl NodeDetailReader for EmbeddedKernelStore {
    async fn load_node_detail(
        &self,
        node_id: &str,
    ) -> Result<Option<NodeDetailProjection>, PortError> {
        let node_id = node_id.to_string();
        self.run(move |store| {
            let tx = store.begin_read()?;
            match tx.get(Table::Details, Key::Str(&node_id))? {
                Some(raw) => Ok(Some(decode::<DetailRecord>("node detail", &raw)?.into())),
                None => Ok(None),
            }
        })
        .await
    }

    async fn load_node_details_batch(
        &self,
        node_ids: Vec<String>,
    ) -> Result<Vec<Option<NodeDetailProjection>>, PortError> {
        self.run(move |store| {
            let tx = store.begin_read()?;
            let mut results = Vec::with_capacity(node_ids.len());
            for node_id in &node_ids {
                results.push(match tx.get(Table::Details, Key::Str(node_id))? {
                    Some(raw) => Some(decode::<DetailRecord>("node detail", &raw)?.into()),
                    None => None,
                });
            }
            Ok(results)
        })
        .await
    }
}