evento-store 0.10.2

A collection of libraries and tools that help you build DDD, CQRS, and event sourcing.
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

use async_trait::async_trait;
use dyn_clone::DynClone;
use evento_query::{CursorType, QueryResult};
use serde_json::Value;

use crate::{
    error::Result,
    store::{Event, WriteEvent},
};

#[cfg(feature = "memory")]
mod memory;
#[cfg(feature = "memory")]
pub use memory::*;

#[cfg(feature = "pg")]
mod pg;
#[cfg(feature = "pg")]
pub use pg::*;

#[async_trait]
pub trait Engine: DynClone + Send + Sync {
    async fn write(
        &self,
        aggregate_id: &'_ str,
        events: Vec<WriteEvent>,
        original_version: u16,
    ) -> Result<Vec<Event>>;

    async fn insert(&self, events: Vec<Event>) -> Result<()>;

    async fn upsert(&self, event: Event) -> Result<()>;

    async fn read(
        &self,
        first: u16,
        after: Option<CursorType>,
        filters: Option<Vec<Value>>,
        aggregate_id: Option<&'_ str>,
    ) -> Result<QueryResult<Event>>;

    async fn last(&self) -> Result<Option<Event>>;
}

dyn_clone::clone_trait_object!(Engine);