distributed 3.3.1

CQRS/ES framework for Rust using Plain Old Rust Structs — append-only events, replay, snapshots, outbox, service bus, and pluggable infrastructure
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

//! Normalized relational read models for the board example. `BoardView`
//! has_many `CardView`; `CardView` belongs_to `BoardView` and stores a JSONB
//! payload column.

mod board_view;
mod card_view;

pub use board_view::BoardView;
pub use card_view::{CardPayload, CardView};

use distributed::{InMemoryReadModelStore, RowKey, RowValue, TableStoreError};

pub fn register_schemas(store: &InMemoryReadModelStore) -> Result<(), TableStoreError> {
    store.register_schema::<BoardView>()?;
    store.register_schema::<CardView>()?;
    Ok(())
}

pub fn board_key(board_id: &str) -> RowKey {
    RowKey::new([("board_id", RowValue::String(board_id.into()))])
}

pub fn card_key(board_id: &str, card_id: &str) -> RowKey {
    RowKey::new([
        ("board_id", RowValue::String(board_id.into())),
        ("card_id", RowValue::String(card_id.into())),
    ])
}