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

//! Selection set -> single SQL statement per root field (dialect-portable JSON tree).
//!
//! # v1 join / PK assumptions
//!
//! Relationship SQL assumes **single-column primary keys** and a single
//! `foreign_key` column per relationship:
//! - **HasMany**: FK lives on the child -> `child.fk = parent.pk`
//! - **BelongsTo**: FK lives on the parent -> `child.pk = parent.fk`
//! - **ManyToMany**: through-table holds both FKs; join helpers emit
//!   through->target ON + through->parent WHERE fragments
//!
//! Multi-column PKs/FKs are out of scope until a dedicated policy task lands
//! (see maintain-3 / maintain-5). Join equality is centralized in
//! [`join_predicate_direct`] / [`join_predicate_m2m_parent`] /
//! [`join_predicate_m2m_target`]. Dialect SQL fragments live on [`DialectOps`].
#![allow(clippy::only_used_in_recursion, clippy::too_many_arguments)]

mod binds;
mod dialect;
mod evidence;
mod filter;
mod projection;
mod relationship;

pub use binds::BindValue;
#[allow(unused_imports)]
pub use dialect::{DialectOps, SqlDialect};
#[allow(unused_imports)]
pub use projection::{
    compile_list_sql_for_test, compile_root, selection_from_field, RootKind, SelectionNode, SqlPlan,
};

#[allow(unused_imports)]
pub(crate) use dialect::{
    join_predicate_direct, join_predicate_m2m_parent, join_predicate_m2m_target,
};
#[allow(unused_imports)]
pub(crate) use evidence::{ExtractedQueryEvidence, QueryRecordEvidence, QueryResponsePathSegment};