this-rs 0.0.9

Framework for building complex multi-entity REST and GraphQL APIs with many relationships
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

//! Persistent event log system for declarative event flows
//!
//! This module provides the `EventLog` trait and implementations for
//! durable event storage, replacing the fire-and-forget `EventBus` as the
//! source of truth for event flows.
//!
//! # Architecture
//!
//! ```text
//! EventBus (broadcast, real-time)
//!     ↓ bridge
//! EventLog (persistent, ordered, replayable)
//!     ↓ subscribe
//! FlowRuntime (consumes events, executes pipelines)
//! ```
//!
//! # Backends
//!
//! - `InMemoryEventLog` — Default, suitable for development and single-instance
//! - Future: NATS JetStream, Kafka, Redis Streams

pub mod compiler;
pub mod context;
pub mod log;
pub mod matcher;
pub mod memory;
pub mod operators;
pub mod runtime;
pub mod sinks;
pub mod types;

pub use compiler::{CompiledFlow, compile_flow, compile_flows};
pub use context::FlowContext;
pub use log::EventLog;
pub use matcher::EventMatcher;
pub use memory::InMemoryEventLog;
pub use runtime::FlowRuntime;
pub use sinks::{InAppNotificationSink, Sink, SinkFactory, SinkRegistry};
pub use types::*;