laminar_core/mv/mod.rs
1//! Cascading materialized view registry with dependency tracking and cycle detection.
2
3mod error;
4mod registry;
5
6pub use error::{MvError, MvState};
7pub use registry::{MaterializedView, MvRegistry};
8
9/// Suffix of the graph operator that owns a changelog view's result slices, beside the
10/// view's own stream operator.
11pub const VIEW_RESULT_OPERATOR_SUFFIX: &str = "::view";
12
13/// The graph operator that owns `view`'s result slices.
14#[must_use]
15pub fn view_result_operator(view: &str) -> String {
16 format!("{view}{VIEW_RESULT_OPERATOR_SUFFIX}")
17}
18
19#[cfg(test)]
20mod tests;