Struct AdaptiveTracker 

pub struct AdaptiveTracker { /* private fields */ }

Adaptive tracker that switches between table and row-level tracking.

When few subscriptions exist for a table, track at row level. When many subscriptions exist, switch to table level.

Implementations

impl AdaptiveTracker

pub fn new(config: AdaptiveTrackingConfig) -> Self

Create a new adaptive tracker.

pub async fn record_subscription( &self, table: &str, row_ids: Option<Vec<String>>, )

Record a subscription for a table.

pub async fn remove_subscription( &self, table: &str, row_ids: Option<Vec<String>>, )

Remove a subscription.

pub async fn evaluate_table(&self, table: &str)

Evaluate and potentially switch tracking mode for a table.

pub async fn evaluate(&self)

Evaluate all tables.

pub async fn should_invalidate(&self, table: &str, row_id: &str) -> bool

Check if a change should be invalidated.

pub async fn get_mode(&self, table: &str) -> TrackingMode

Get the current tracking mode for a table.

pub async fn stats(&self) -> AdaptiveTrackingStats

Get tracking statistics.

pub async fn clear(&self)

Clear all tracking state.