Struct RedisSentinelHandle 

pub struct RedisSentinelHandle { /* private fields */ }

A running Redis Sentinel topology. Stops everything on Drop.

Implementations

impl RedisSentinelHandle

pub fn master_addr(&self) -> String

The master’s address.

pub fn monitored_master_names(&self) -> Vec<&str>

All monitored master names.

pub fn monitored_master_addrs(&self) -> Vec<String>

All monitored master addresses.

pub fn pids(&self) -> Vec<u32>

The PIDs of all processes in the topology (master, replicas, sentinels).

pub fn sentinel_addrs(&self) -> Vec<String>

All sentinel addresses.

pub fn master_name(&self) -> &str

The monitored master name.

pub async fn poke(&self) -> Result<HashMap<String, String>>

Query a sentinel for the primary monitored master’s status.

Iterates over the sentinel processes until one responds, then runs SENTINEL MASTER <name> and returns the result as a flat key/value map.

Common keys in the returned map include "ip", "port", "flags", "num-slaves", and "num-other-sentinels".

Returns Error::NoReachableSentinel if no sentinel responds.

pub async fn poke_master( &self, master_name: &str, ) -> Result<HashMap<String, String>>

Query a sentinel for a specific monitored master’s status.

Like poke but targets master_name instead of the primary master configured for this topology.

pub async fn is_healthy(&self) -> bool

Check if the topology is healthy.

pub async fn wait_for_healthy(&self, timeout: Duration) -> Result<()>

Wait until the topology is healthy or timeout.

pub fn stop(&self)

Stop everything via an escalating shutdown strategy.

1. Sends SHUTDOWN NOSAVE to each sentinel process.
2. Waits 500ms for them to exit.
3. For each sentinel PID that is still alive, calls crate::process::force_kill.
4. Calls crate::process::kill_by_port for each sentinel port as a safety net.

Replicas and the master are stopped by their own handles’ Drop impls, which also use the escalating strategy.

Trait Implementations

impl Drop for RedisSentinelHandle

fn drop(&mut self)

Executes the destructor for this type.