Struct AtomicAllShards 

pub struct AtomicAllShards<'a> { /* private fields */ }

Context handed to the atomic_all_shards closure body. Methods route to the right shard by hashing the key.

Implementations

impl<'a> AtomicAllShards<'a>

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

SET key value — always succeeds.

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

GET key.

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

INCR key.

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

INCRBY key delta.

pub fn hset(&mut self, key: &[u8], pairs: &[(&[u8], &[u8])]) -> Result<usize>

HSET key field value [field value ...]. Returns count newly added (existing fields are overwritten but not counted).

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

HGET key field — None when the key or field is absent.

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

HINCRBY key field delta — returns the field’s new value.

pub fn zadd(&mut self, key: &[u8], pairs: &[(f64, &[u8])]) -> Result<usize>

ZADD key score member [score member ...]. Returns count newly added (score updates of existing members are not counted).

pub fn zincrby(&mut self, key: &[u8], delta: f64, member: &[u8]) -> Result<f64>

ZINCRBY key delta member — returns the member’s new score.

pub fn zscore(&mut self, key: &[u8], member: &[u8]) -> Result<Option<f64>>

ZSCORE key member (v2.1: parity with super::ops_atomic::AtomicCtx).

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

DEL key [key ...] — keys may span shards; each key’s delete is applied and AOF-logged on its own shard.

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

EXISTS key [key ...] — count of the given keys that exist.

pub fn hdel(&mut self, key: &[u8], fields: &[&[u8]]) -> Result<usize>

HDEL key field [field ...].

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

HGETALL key — (field, value) pairs.

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

HMGET key field [field ...] — None per absent field.

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

HEXISTS key field.

pub fn sadd(&mut self, key: &[u8], members: &[&[u8]]) -> Result<usize>

SADD key member [member ...].

pub fn srem(&mut self, key: &[u8], members: &[&[u8]]) -> Result<usize>

SREM key member [member ...].

pub fn lpush(&mut self, key: &[u8], values: &[&[u8]]) -> Result<usize>

LPUSH key value [value ...] — returns the new list length.

pub fn rpush(&mut self, key: &[u8], values: &[&[u8]]) -> Result<usize>

RPUSH key value [value ...] — returns the new list length.

pub fn zrem(&mut self, key: &[u8], members: &[&[u8]]) -> Result<usize>

ZREM key member [member ...].

pub fn zcard(&mut self, key: &[u8]) -> Result<usize>

ZCARD key — member count; 0 when absent.

pub fn zadd_flags( &mut self, key: &[u8], pairs: &[(f64, &[u8])], flags: ZaddFlags, ) -> Result<ZaddReport>

Flags-aware ZADD (v2.1). AOF logs the applied pairs as plain ZADD — the effect, never the condition (deterministic replay).