Struct AtomicCtx 

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

Handle passed to the atomic closure body. Methods mirror the equivalent Store ops but operate on the already-held write lock, so reads inside the block see the closure’s own writes.

Implementations

impl AtomicCtx<'_>

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

SET key value. Returns true (SET always succeeds without NX/XX veto).

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

GET key.

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

INCR key — by 1.

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.

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

HGET key field.

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

HINCRBY key field delta.

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

ZADD key score member.

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

ZINCRBY key delta member.

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

ZSCORE key member.

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

DEL key [key ...] — every key must hash to this 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; reads see the closure’s own prior writes.

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).