Struct AsyncClusterClient 

pub struct AsyncClusterClient { /* private fields */ }

One open connection per distinct shard node + a slot→shard table.

Implementations

impl AsyncClusterClient

pub async fn connect(host: &str, port: u16) -> Result<Self>

Connect via a seed node, discover topology, open one connection per shard.

pub fn shard_count(&self) -> usize

Number of distinct shard nodes.

pub async fn request_keyed( &mut self, key: &[u8], args: &[Vec<u8>], ) -> Result<Reply>

Route a single-key command to its owner shard.

pub async fn request_unkeyed(&mut self, args: &[Vec<u8>]) -> Result<Reply>

Keyless command — answered identically by any shard.

pub async fn ping(&mut self) -> Result<()>

PING. Answered by any shard.

pub async fn publish(&mut self, channel: &[u8], message: &[u8]) -> Result<usize>

PUBLISH channel message. Returns subscriber count.

pub async fn set(&mut self, key: &[u8], value: &[u8]) -> Result<()>

SET key value.

pub async fn set_with_ttl( &mut self, key: &[u8], value: &[u8], ttl: Duration, ) -> Result<()>

SET key value PX ttl_ms.

pub async fn get(&mut self, key: &[u8]) -> Result<Option<Vec<u8>>>

GET key.

pub async fn incr(&mut self, key: &[u8]) -> Result<i64>

INCR key.

pub async fn incr_by(&mut self, key: &[u8], delta: i64) -> Result<i64>

INCRBY key delta.

pub async fn expire(&mut self, key: &[u8], ttl: Duration) -> Result<bool>

PEXPIRE key ttl_ms.

pub async fn persist(&mut self, key: &[u8]) -> Result<bool>

PERSIST key.

pub async fn ttl_ms(&mut self, key: &[u8]) -> Result<i64>

PTTL key.

pub async fn del(&mut self, keys: &[&[u8]]) -> Result<usize>

DEL key [key ...] — routed per key, summed.

pub async fn exists(&mut self, keys: &[&[u8]]) -> Result<usize>

EXISTS key [key ...] — routed per key, summed.

pub async fn dbsize(&mut self) -> Result<usize>

DBSIZE — cluster-wide total (server fans out internally).

pub async fn flushall(&mut self) -> Result<()>

FLUSHALL — clears every shard.