distributed 1.3.0

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
29
30
31
32
33
34
35
36
37
38
39

use crate::entity::Entity;
use crate::outbox::OutboxMessage;
use crate::read_model::ReadModelWritePlan;
use crate::snapshot::SnapshotRecord;

use super::inbox::InboxReceipt;

/// A snapshot write staged as part of a transactional commit.
#[derive(Clone, Debug)]
pub enum SnapshotWrite {
    Save(SnapshotRecord),
}

/// A structured set of writes that must commit under one transaction boundary.
pub struct CommitBatch<'a> {
    pub entities: Vec<&'a mut Entity>,
    pub outbox_messages: Vec<OutboxMessage>,
    pub read_model_plans: Vec<ReadModelWritePlan>,
    pub snapshots: Vec<SnapshotWrite>,
    /// Consumer inbox receipts to record in the same transaction (the optional
    /// effectively-once effect fence). Empty for the default idempotent path.
    pub inbox_receipts: Vec<InboxReceipt>,
}

impl<'a> CommitBatch<'a> {
    pub fn new(entities: Vec<&'a mut Entity>) -> Self {
        Self {
            entities,
            outbox_messages: Vec::new(),
            read_model_plans: Vec::new(),
            snapshots: Vec::new(),
            inbox_receipts: Vec::new(),
        }
    }

    pub fn empty() -> Self {
        Self::new(Vec::new())
    }
}