Struct RedisWatcher 

pub struct RedisWatcher { /* private fields */ }

Implementations

impl RedisWatcher

pub fn new(redis_url: &str, options: WatcherOptions) -> Result<Self>

Create a new Redis watcher for standalone Redis

pub fn new_cluster(cluster_urls: &str, options: WatcherOptions) -> Result<Self>

Create a new Redis watcher for Redis Cluster

Note: Redis Cluster PubSub messages don’t propagate between nodes. All instances MUST connect to the SAME node for pub/sub to work. This method uses the first URL as the fixed PubSub node.

Arguments

• cluster_urls - Comma-separated Redis URLs (first URL used for PubSub)
• options - Watcher configuration options

pub async fn wait_for_ready(&self)

Wait for subscription to be ready (similar to Go’s WaitGroup.Wait())

This ensures that the watcher is fully subscribed before publishing messages. Recommended to call this after creating the watcher and before any policy operations.

Trait Implementations

impl Drop for RedisWatcher

fn drop(&mut self)

Executes the destructor for this type.

impl Watcher for RedisWatcher

fn set_update_callback(&mut self, cb: Box<dyn FnMut(String) + Send + Sync>)

fn update(&mut self, d: EventData)