distributed 4.2.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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

//! Adapter-neutral, deterministic domain-event projection programs.
//!
//! This module models what a domain event means for read models. It does not
//! know how any ORM, database, projector lease, or client cache applies that
//! meaning. Downstream adapters lower a resolved plan without changing its
//! semantics.

#![deny(missing_docs)]

mod canonical;
mod error;
mod expression;
mod plan;
mod program;
mod provenance;

// Public module paths are reserved for downstream implementations. The empty
// seams intentionally expose no lowering, catalog, placement, or executor
// contract before their owning tasks define one.
pub mod catalog;
pub mod executor;
pub mod local_mounts;
pub mod lower;
pub mod placement;

pub use local_mounts::{
    LocalDirectMount, LocalEventualMount, LocalProjectionMounts, LocalProjectionMountsBuilder,
};

pub use error::ProjectionProgramError;
pub use expression::{
    ProjectionAssignment, ProjectionEnvelopeField, ProjectionExpression,
    ProjectionObjectValueField, ProjectionScalarTransform, ProjectionValue, ProjectionValueRef,
    ProjectionValueType, ResolvedProjectionValue, MAX_PROJECTION_EXPRESSION_DEPTH,
    MAX_PROJECTION_PATH_SEGMENTS,
};
pub(crate) use expression::{ProjectionAssignmentRef, ProjectionExpressionRef};
pub use plan::{
    ProjectionMutationProvenance, ProjectionOccurrenceProvenance, ResolvedProjectionField,
    ResolvedProjectionKey, ResolvedProjectionKeyField, ResolvedProjectionMutation,
    ResolvedProjectionMutationScope, ResolvedProjectionPartition, ResolvedProjectionPartitionRef,
    ResolvedProjectionPlan, ResolvedProjectionRelationshipEffect,
};
pub use program::{
    ProjectionArm, ProjectionEventSet, ProjectionField, ProjectionKeyField, ProjectionMutationKind,
    ProjectionOperation, ProjectionPartition, ProjectionPlanTemplate, ProjectionProgram,
    ProjectionProgramId, ProjectionProgramLimits, ProjectionRelationshipEffect,
    ProjectionRelationshipEffectKind, MAX_PROJECTION_OPERATIONS_PER_OCCURRENCE,
    PROJECTION_OPERATION_SEMANTICS_VERSION, PROJECTION_PROGRAM_IR_VERSION,
};
pub use provenance::{
    ProjectionEventSelector, ProjectionInvalidation, ProjectionRelationship, ProjectionTarget,
};

#[cfg(test)]
mod tests;