distributed 1.7.2

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
use distributed::ReadModel;
use serde::{Deserialize, Serialize};

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize, ReadModel)]
#[table("checkout_steps")]
#[readmodel(primary_key = ["checkout_id", "step"])]
pub struct CheckoutStepView {
    #[readmodel(
        foreign_key = "checkouts.checkout_id",
        delegated_from = "CheckoutView.checkout_id"
    )]
    pub checkout_id: String,
    pub step: String,
    pub detail: String,
}