Struct Pipeline 

pub struct Pipeline { /* private fields */ }

A batch of commands to be sent in a single network round-trip.

Build the pipeline with the typed builder methods, then execute it with [Client::execute_pipeline].

Implementations

impl Pipeline

pub fn new() -> Self

Creates an empty pipeline.

pub fn len(&self) -> usize

Returns the number of queued commands.

pub fn is_empty(&self) -> bool

Returns true if no commands have been queued.

pub fn send(self, args: &[&str]) -> Self

Queues a raw command from string slices.

Useful for commands not covered by the typed builders.

pub fn get(self, key: &str) -> Self

Queues a GET key command.

pub fn set(self, key: &str, value: impl AsRef<[u8]>) -> Self

Queues a SET key value command.

pub fn del(self, keys: &[&str]) -> Self

Queues a DEL key [key ...] command.

pub fn expire(self, key: &str, seconds: u64) -> Self

Queues an EXPIRE key seconds command.

pub fn incr(self, key: &str) -> Self

Queues an INCR key command.

pub fn decr(self, key: &str) -> Self

Queues a DECR key command.

pub fn incrby(self, key: &str, delta: i64) -> Self

Queues an INCRBY key delta command.

pub fn ping(self) -> Self

Queues a PING command.

pub fn exists(self, keys: &[&str]) -> Self

Queues an EXISTS key [key ...] command.

pub fn ttl(self, key: &str) -> Self

Queues a TTL key command.

pub fn lpush<V: AsRef<[u8]>>(self, key: &str, values: &[V]) -> Self

Queues an LPUSH key value [value ...] command.

pub fn rpush<V: AsRef<[u8]>>(self, key: &str, values: &[V]) -> Self

Queues an RPUSH key value [value ...] command.

pub fn lpop(self, key: &str) -> Self

Queues an LPOP key command.

pub fn rpop(self, key: &str) -> Self

Queues an RPOP key command.

pub fn llen(self, key: &str) -> Self

Queues an LLEN key command.

pub fn hget(self, key: &str, field: &str) -> Self

Queues an HGET key field command.

pub fn hset<V: AsRef<[u8]>>(self, key: &str, pairs: &[(&str, V)]) -> Self

Queues an HSET key field value [field value ...] command.

pub fn hdel(self, key: &str, fields: &[&str]) -> Self

Queues an HDEL key field [field ...] command.

pub fn hincrby(self, key: &str, field: &str, delta: i64) -> Self

Queues an HINCRBY key field delta command.

pub fn sadd(self, key: &str, members: &[&str]) -> Self

Queues an SADD key member [member ...] command.

pub fn srem(self, key: &str, members: &[&str]) -> Self

Queues an SREM key member [member ...] command.

pub fn scard(self, key: &str) -> Self

Queues an SCARD key command.

pub fn zadd(self, key: &str, members: &[(f64, &str)]) -> Self

Queues a ZADD key score member [score member ...] command.

pub fn zcard(self, key: &str) -> Self

Queues a ZCARD key command.

pub fn zscore(self, key: &str, member: &str) -> Self

Queues a ZSCORE key member command.

pub fn strlen(self, key: &str) -> Self

Queues a STRLEN key command.

pub fn incr_by_float(self, key: &str, delta: f64) -> Self

Queues an INCRBYFLOAT key delta command.

pub fn key_type(self, key: &str) -> Self

Queues a TYPE key command.

pub fn keys(self, pattern: &str) -> Self

Queues a KEYS pattern command.

pub fn rename(self, key: &str, newkey: &str) -> Self

Queues a RENAME key newkey command.

pub fn pexpire(self, key: &str, millis: u64) -> Self

Queues a PEXPIRE key millis command.

pub fn unlink(self, keys: &[&str]) -> Self

Queues an UNLINK key [key ...] command.

pub fn hmget(self, key: &str, fields: &[&str]) -> Self

Queues an HMGET key field [field ...] command.

pub fn echo(self, message: &str) -> Self

Queues an ECHO message command.

pub fn publish(self, channel: &str, message: impl AsRef<[u8]>) -> Self

Queues a PUBLISH channel message command.

Trait Implementations

impl Default for Pipeline

fn default() -> Self

Returns the “default value” for a type.