reifydb_sub_flow/lib.rs
1// SPDX-License-Identifier: Apache-2.0
2// Copyright (c) 2026 ReifyDB
3
4//! Streaming flow runtime: evaluates registered flow definitions over the change stream from the
5//! transaction layer and writes the resulting deltas back into the catalog.
6//!
7//! Invariant: a flow's output is fully determined by its definition, so an operator carrying
8//! hidden state (a clock, a random number, an external read) breaks replay.
9
10#![cfg_attr(not(debug_assertions), deny(clippy::disallowed_methods))]
11#![cfg_attr(debug_assertions, warn(clippy::disallowed_methods))]
12#![cfg_attr(not(debug_assertions), deny(warnings))]
13#![allow(clippy::tabs_in_doc_comments)]
14
15pub mod builder;
16pub(crate) mod catalog;
17pub(crate) mod commit;
18pub(crate) mod control;
19pub(crate) mod discovery;
20pub mod error;
21pub mod operator;
22pub(crate) mod progress;
23pub mod subsystem;