Struct ClusterTopology 

pub struct ClusterTopology { /* private fields */ }

Manages cluster topology and slot mappings

Implementations

impl ClusterTopology

pub fn new() -> Self

Create a new cluster topology

pub async fn get_node_for_slot(&self, slot: u16) -> Option<(String, u16)>

Get the node address for a given slot

pub async fn get_node_for_key(&self, key: &[u8]) -> Option<(String, u16)>

Get the node address for a given key

pub async fn update_slot_mapping(&self, slot: u16, host: String, port: u16)

Update the slot mapping when a MOVED redirect occurs

pub async fn clear_slots(&self)

Clear all slot mappings (useful for full topology refresh)

pub async fn update_from_cluster_slots( &self, slots_data: Vec<Vec<(i64, String, i64)>>, ) -> RedisResult<()>

Update the topology from CLUSTER SLOTS response

The response is an array of slot ranges, where each range is: [start_slot, end_slot, [master_host, master_port], [replica_host, replica_port], …]

pub async fn get_all_nodes(&self) -> Vec<NodeInfo>

Get all known nodes

pub async fn mapped_slots_count(&self) -> usize

Get the number of slots currently mapped

Trait Implementations

impl Clone for ClusterTopology

fn clone(&self) -> ClusterTopology

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for ClusterTopology

fn default() -> Self

Returns the “default value” for a type.