Struct CascadeInvalidator 

pub struct CascadeInvalidator { /* private fields */ }

Tracks transitive view-to-view dependencies for cascading invalidation.

Architecture

When v_user depends on v_raw_user, and v_analytics depends on v_user:

v_raw_user (source)
   ↓ (depends on)
v_user (intermediate)
   ↓ (depends on)
v_analytics (leaf)

Invalidating v_raw_user cascades to invalidate v_user and v_analytics.

Example

use fraiseql_core::cache::cascade_invalidator::CascadeInvalidator;

let mut invalidator = CascadeInvalidator::new();

// Register that v_user depends on v_raw_user
invalidator.add_dependency("v_user", "v_raw_user").unwrap();

// Register that v_analytics depends on v_user
invalidator.add_dependency("v_analytics", "v_user").unwrap();

// Invalidate v_raw_user - cascades to v_user and v_analytics
let affected = invalidator.cascade_invalidate("v_raw_user").unwrap();
assert_eq!(affected.len(), 3); // v_raw_user, v_user, v_analytics

Implementations

impl CascadeInvalidator

pub fn new() -> Self

Create new cascade invalidator.

pub fn add_dependency( &mut self, dependent_view: &str, dependency_view: &str, ) -> Result<()>

Register a view dependency.

Declares that dependent_view depends on dependency_view. When dependency_view is invalidated, dependent_view will also be invalidated.

Arguments

• dependent_view - View that depends on another
• dependency_view - View that is depended upon

Example

use fraiseql_core::cache::cascade_invalidator::CascadeInvalidator;

let mut invalidator = CascadeInvalidator::new();
invalidator.add_dependency("v_analytics", "v_user").unwrap();

pub fn cascade_invalidate(&mut self, view: &str) -> Result<HashSet<String>>

Cascade invalidate a view and all dependent views.

Uses breadth-first search to find all views that transitively depend on the given view, and returns the complete set of invalidated views.

Algorithm

1. Start with the target view
2. Find all views that directly depend on it
3. For each dependent, recursively find views that depend on it
4. Return complete set (target + all transitive dependents)

Arguments

• view - View to invalidate

Returns

Set of all invalidated views (including the target)

Example

use fraiseql_core::cache::cascade_invalidator::CascadeInvalidator;

let mut invalidator = CascadeInvalidator::new();
invalidator.add_dependency("v_user_stats", "v_user").unwrap();
invalidator.add_dependency("v_dashboard", "v_user_stats").unwrap();

let invalidated = invalidator.cascade_invalidate("v_user").unwrap();
assert!(invalidated.contains("v_user"));
assert!(invalidated.contains("v_user_stats"));
assert!(invalidated.contains("v_dashboard"));

pub fn get_direct_dependents(&self, view: &str) -> HashSet<String>

Get all views that depend on a given view (direct dependents only).

For transitive dependents, use cascade_invalidate().

Arguments

• view - View to query

Returns

Set of views that directly depend on the given view

pub fn get_direct_dependencies(&self, view: &str) -> HashSet<String>

Get all views that a given view depends on (direct dependencies only).

Arguments

• view - View to query

Returns

Set of views that the given view depends on

pub fn get_transitive_dependents(&self, view: &str) -> HashSet<String>

Get all views that transitively depend on a given view.

Like cascade_invalidate() but non-mutating (for queries).

Arguments

• view - View to query

Returns

Set of all transitive dependents (including the view itself)

pub fn has_dependency_path(&self, dependent: &str, dependency: &str) -> bool

Check if there’s a dependency path between two views.

Returns true if dependent transitively depends on dependency.

Arguments

• dependent - Potentially dependent view
• dependency - Potentially depended-upon view

Returns

true if there’s a transitive dependency

pub fn stats(&self) -> InvalidationStats

Get cascade invalidation statistics.

pub fn clear(&mut self)

Clear all registered dependencies.

pub fn view_count(&self) -> usize

Get total number of views tracked.

pub fn dependency_count(&self) -> usize

Get total number of dependency edges.

Trait Implementations

impl Clone for CascadeInvalidator

fn clone(&self) -> CascadeInvalidator

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CascadeInvalidator

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

Formats the value using the given formatter.

impl Default for CascadeInvalidator

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for CascadeInvalidator

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CascadeInvalidator

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.