Struct WatchRegistry 

pub struct WatchRegistry { /* private fields */ }

Watch registry - manages watcher registration (Arc-shareable)

This is the shared state that both Builder (for registration) and WatchDispatcher (for event dispatch) can access concurrently.

Implementations

impl WatchRegistry

pub fn new( watcher_buffer_size: usize, unregister_tx: UnboundedSender<(u64, Bytes)>, ) -> Self

Create a new watch registry

Arguments

• watcher_buffer_size - Buffer size for per-watcher mpsc channels
• unregister_tx - Channel for receiving unregister requests

pub fn register(&self, key: Bytes) -> WatcherHandle

Register a new watcher for a specific key

Returns a handle that receives watch events via an mpsc channel. The watcher is automatically unregistered when the handle is dropped.