Struct MvRegistry 

pub struct MvRegistry { /* private fields */ }

Registry for managing materialized views.

Maintains a DAG of view dependencies and provides:

• Cycle detection on registration
• Topological ordering for correct processing order
• Dependency tracking for cascade operations

Example

use laminar_core::mv::{MvRegistry, MaterializedView};
use arrow_schema::{Schema, Field, DataType};
use std::sync::Arc;

let mut registry = MvRegistry::new();

// Register base tables
registry.register_base_table("trades");

// Register cascading views
let schema = Arc::new(Schema::new(vec![Field::new("count", DataType::Int64, false)]));
let ohlc_1s = MaterializedView::new("ohlc_1s", "SELECT ...", vec!["trades".into()], schema.clone());
registry.register(ohlc_1s).unwrap();

let ohlc_1m = MaterializedView::new("ohlc_1m", "SELECT ...", vec!["ohlc_1s".into()], schema);
registry.register(ohlc_1m).unwrap();

// Views are processed in topological order
assert_eq!(registry.topo_order(), &["ohlc_1s", "ohlc_1m"]);

Implementations

impl MvRegistry

pub fn new() -> Self

Creates an empty registry.

pub fn register_base_table(&mut self, name: impl Into<String>)

Registers a base table (source that is not an MV).

Base tables are assumed to exist and can be referenced as sources by materialized views.

pub fn is_base_table(&self, name: &str) -> bool

Returns true if the given name is a registered base table.

pub fn register(&mut self, view: MaterializedView) -> Result<(), MvError>

Registers a new materialized view.

Errors

Returns error if:

• View name already exists
• Source MV or base table doesn’t exist
• Would create a dependency cycle

pub fn unregister(&mut self, name: &str) -> Result<MaterializedView, MvError>

Unregisters a materialized view.

Errors

Returns error if:

• View doesn’t exist
• Other views depend on it (use unregister_cascade instead)

pub fn unregister_cascade( &mut self, name: &str, ) -> Result<Vec<MaterializedView>, MvError>

Unregisters a materialized view and all views that depend on it.

Returns the views that were removed, in dependency order (dependents first).

Errors

Returns error if the view doesn’t exist.

pub fn get(&self, name: &str) -> Option<&MaterializedView>

Gets a view by name.

pub fn get_mut(&mut self, name: &str) -> Option<&mut MaterializedView>

Gets a mutable reference to a view by name.

pub fn topo_order(&self) -> &[String]

Returns all views in topological order (dependencies first).

pub fn get_dependents(&self, source: &str) -> impl Iterator<Item = &str>

Returns all views that depend on the given source.

pub fn get_dependencies(&self, view: &str) -> impl Iterator<Item = &str>

Returns all sources that the given view depends on.

pub fn len(&self) -> usize

Returns the number of registered views.

pub fn is_empty(&self) -> bool

Returns true if no views are registered.

pub fn views(&self) -> impl Iterator<Item = &MaterializedView>

Returns an iterator over all registered views.

pub fn base_tables(&self) -> &FxHashSet<String>

Returns the set of registered base tables.

pub fn dependency_chain(&self, name: &str) -> Vec<String>

Returns the full dependency chain for a view (including transitive).

The chain is returned in topological order (dependencies first).

Trait Implementations

impl Debug for MvRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MvRegistry

fn default() -> MvRegistry

Returns the “default value” for a type.