framework-cqrs-lib 0.3.1

handle state-machine with data persist in journal and store mongo for restfull actix api
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use async_trait::async_trait;

use crate::cqrs::core::repositories::query::Query;
use crate::cqrs::models::errors::ResultErr;

pub trait DAO<DBO, ID>: ReadOnlyDAO<DBO, ID> + WriteOnlyDAO<DBO, ID> + Sync + Send {}

#[async_trait]
pub trait ReadOnlyDAO<DBO, ID> {
    async fn fetch_one(&self, id: &ID) -> ResultErr<Option<DBO>>;
    async fn fetch_all(&self, query: Query) -> ResultErr<Vec<DBO>>;
}

#[async_trait]
pub trait WriteOnlyDAO<DBO, ID> {
    async fn insert(&self, entity: &DBO, entity_id: &ID) -> ResultErr<ID>;
    async fn update(&self, id: &ID, entity: &DBO) -> ResultErr<ID>;
    // async fn delete(&self, id: &ID) -> ResultErr<ID>;
}