cqrs-es2-sql 0.1.0

A SQL implementation of an event store for cqrs-es2.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use postgres::Client;

use cqrs_es2::{
    CqrsFramework,
    IAggregate,
    IQueryProcessor,
};

use crate::stores::EventStore;

/// A convenience type for creating a CqrsFramework backed by
/// EventStore and using a simple metadata supplier with time of
/// commit.
pub type Cqrs<A> = CqrsFramework<A, EventStore<A>>;

/// A convenience function for creating a CqrsFramework
pub fn get_cqrs<A: IAggregate>(
    conn: Client,
    query_processor: Vec<Box<dyn IQueryProcessor<A>>>,
) -> Cqrs<A> {
    let store = EventStore::new(conn);
    CqrsFramework::new(store, query_processor)
}