storage-kit 0.0.1

Portable database and transactional state-store Kit.
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

use crate::{
    StateKey, StateListRequest, StateListResponse, StateRecordSnapshot, StateStoreBackend,
    StateStoreError, state_stores::config::RedbStateStoreConfig,
};

use super::executor::RedbExecutor;

pub(crate) struct RedbStateStore {
    executor: RedbExecutor,
}

impl RedbStateStore {
    pub(crate) async fn connect(config: RedbStateStoreConfig) -> Result<Self, StateStoreError> {
        config.validate()?;
        RedbExecutor::start(config)
            .await
            .map(|executor| Self { executor })
    }
}

impl StateStoreBackend for RedbStateStore {
    type Transaction = super::RedbStateTransaction;

    async fn load(&self, key: StateKey) -> Result<Option<StateRecordSnapshot>, StateStoreError> {
        self.executor.load(key).await
    }

    async fn list(&self, request: StateListRequest) -> Result<StateListResponse, StateStoreError> {
        self.executor.list(request).await
    }

    async fn begin_transaction(&self) -> Result<Self::Transaction, StateStoreError> {
        self.executor.begin_transaction().await
    }
}