event-store-adapter-rs 2.0.1

Event Store adapter for CQRS/Event Sourcing with DynamoDB, Bigtable, SQLite and in-memory backends
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

use std::fmt::Debug;

use crate::types::{Aggregate, AggregateId, Event, EventStoreReadError, EventStoreWriteError};
use async_trait::async_trait;
use chrono::Duration;

#[derive(Debug, Clone, PartialEq)]
pub struct SnapshotEnvelope<A> {
  pub aggregate: A,
  pub seq_nr: usize,
  pub version: usize,
}

#[derive(Debug, Clone, Default, PartialEq)]
pub struct SnapshotMaintenance {
  pub keep_snapshot_count: Option<usize>,
  pub delete_ttl: Option<Duration>,
}

#[async_trait]
pub trait StorageBackend<AID, A, E>: Send + Sync + Clone + Debug + 'static
where
  AID: AggregateId,
  A: Aggregate<ID = AID>,
  E: Event<AggregateID = AID>, {
  async fn fetch_latest_snapshot(&self, aid: &AID) -> Result<Option<SnapshotEnvelope<A>>, EventStoreReadError>;

  async fn fetch_events_since(&self, aid: &AID, seq_nr: usize) -> Result<Vec<E>, EventStoreReadError>;

  async fn create_event_and_snapshot(
    &self,
    event: &E,
    aggregate: &A,
    maintenance: &SnapshotMaintenance,
  ) -> Result<(), EventStoreWriteError>;

  async fn update_event_and_snapshot(
    &self,
    event: &E,
    aggregate: Option<&A>,
    expected_version: usize,
    maintenance: &SnapshotMaintenance,
  ) -> Result<(), EventStoreWriteError>;

  async fn on_event_persisted(
    &self,
    _aid: &AID,
    _maintenance: &SnapshotMaintenance,
  ) -> Result<(), EventStoreWriteError> {
    Ok(())
  }
}