Struct ConfigWatcher 

pub struct ConfigWatcher { /* private fields */ }

SSE-based watcher that delivers ConfigChangedEvents via a broadcast channel.

Multiple subscribers can subscribe() to receive events independently. Call start() to begin streaming. Call stop() to shut down.

Implementations

impl ConfigWatcher

pub fn subscribe(&self) -> Receiver<ConfigChangedEvent>

Subscribe to config-changed events.

Returns a broadcast::Receiver. Call start() to begin streaming events.

pub fn start(&self)

Start the SSE streaming loop in the background.

This spawns a Tokio task that connects to the /events endpoint and delivers deserialized ConfigChangedEvents to all subscribers. Reconnects automatically on connection failure after reconnect_delay.

pub fn stop(&self)

Stop the watcher by dropping the sender, which closes all receivers.

pub fn with_reconnect_delay(self, delay: Duration) -> Self

Set a custom reconnect delay (default: 5 seconds).