Struct WatchManager 

pub struct WatchManager { /* private fields */ }

Manager for watch subscriptions.

Handles creating, tracking, and cancelling watches. Uses a Mutex internally but operations are fast (no I/O).

Implementations

impl WatchManager

pub fn new() -> Self

Create a new watch manager with default settings.

pub fn with_buffer_size(buffer_size: usize) -> Self

Create a new watch manager with a custom channel buffer size.

pub fn create_watch(&self, node_hash: NodeHash) -> Watch

Create a new watch for a node.

Returns a Watch that will receive snapshot updates for the specified node.

pub fn cancel_watch(&self, watch_id: WatchId)

Cancel a watch subscription.

The watch will no longer receive updates.

pub fn notify(&self, node_hash: NodeHash, snapshot: Arc<Snapshot>)

Notify all watches for a node about a snapshot update.

Removes any closed watches automatically.

pub fn watch_count(&self, node_hash: NodeHash) -> usize

Get the number of active watches for a node.

pub fn total_watch_count(&self) -> usize

Get the total number of active watches across all nodes.

Trait Implementations

impl Debug for WatchManager

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

Formats the value using the given formatter.

impl Default for WatchManager

fn default() -> Self

Returns the “default value” for a type.