Enum ShardRequest 

pub enum ShardRequest {
    Get {
        key: String,
    },
    Set {
        key: String,
        value: Bytes,
        expire: Option<Duration>,
        nx: bool,
        xx: bool,
    },
    Incr {
        key: String,
    },
    Decr {
        key: String,
    },
    Del {
        key: String,
    },
    Exists {
        key: String,
    },
    Expire {
        key: String,
        seconds: u64,
    },
    Ttl {
        key: String,
    },
    Persist {
        key: String,
    },
    Pttl {
        key: String,
    },
    Pexpire {
        key: String,
        milliseconds: u64,
    },
    LPush {
        key: String,
        values: Vec<Bytes>,
    },
    RPush {
        key: String,
        values: Vec<Bytes>,
    },
    LPop {
        key: String,
    },
    RPop {
        key: String,
    },
    LRange {
        key: String,
        start: i64,
        stop: i64,
    },
    LLen {
        key: String,
    },
    Type {
        key: String,
    },
    ZAdd {
        key: String,
        members: Vec<(f64, String)>,
        nx: bool,
        xx: bool,
        gt: bool,
        lt: bool,
        ch: bool,
    },
    ZRem {
        key: String,
        members: Vec<String>,
    },
    ZScore {
        key: String,
        member: String,
    },
    ZRank {
        key: String,
        member: String,
    },
    ZCard {
        key: String,
    },
    ZRange {
        key: String,
        start: i64,
        stop: i64,
        with_scores: bool,
    },
    HSet {
        key: String,
        fields: Vec<(String, Bytes)>,
    },
    HGet {
        key: String,
        field: String,
    },
    HGetAll {
        key: String,
    },
    HDel {
        key: String,
        fields: Vec<String>,
    },
    HExists {
        key: String,
        field: String,
    },
    HLen {
        key: String,
    },
    HIncrBy {
        key: String,
        field: String,
        delta: i64,
    },
    HKeys {
        key: String,
    },
    HVals {
        key: String,
    },
    HMGet {
        key: String,
        fields: Vec<String>,
    },
    SAdd {
        key: String,
        members: Vec<String>,
    },
    SRem {
        key: String,
        members: Vec<String>,
    },
    SMembers {
        key: String,
    },
    SIsMember {
        key: String,
        member: String,
    },
    SCard {
        key: String,
    },
    DbSize,
    Stats,
    Snapshot,
    RewriteAof,
    FlushDb,
    Scan {
        cursor: u64,
        count: usize,
        pattern: Option<String>,
    },
}

A protocol-agnostic command sent to a shard.

Variants

Get

Fields

key: String

Set

Fields

key: String

value: Bytes

expire: Option<Duration>

nx: bool

Only set the key if it does not already exist.

xx: bool

Only set the key if it already exists.

Incr

Fields

key: String

Decr

Fields

key: String

Del

Fields

key: String

Exists

Fields

key: String

Expire

Fields

key: String

seconds: u64

Ttl

Fields

key: String

Persist

Fields

key: String

Pttl

Fields

key: String

Pexpire

Fields

key: String

milliseconds: u64

LPush

Fields

key: String

values: Vec<Bytes>

RPush

Fields

key: String

values: Vec<Bytes>

LPop

Fields

key: String

RPop

Fields

key: String

LRange

Fields

key: String

start: i64

stop: i64

LLen

Fields

key: String

Type

Fields

key: String

ZAdd

Fields

key: String

members: Vec<(f64, String)>

nx: bool

xx: bool

gt: bool

lt: bool

ch: bool

ZRem

Fields

key: String

members: Vec<String>

ZScore

Fields

key: String

member: String

ZRank

Fields

key: String

member: String

ZCard

Fields

key: String

ZRange

Fields

key: String

start: i64

stop: i64

with_scores: bool

HSet

Fields

key: String

fields: Vec<(String, Bytes)>

HGet

Fields

key: String

field: String

HGetAll

Fields

key: String

HDel

Fields

key: String

fields: Vec<String>

HExists

Fields

key: String

field: String

HLen

Fields

key: String

HIncrBy

Fields

key: String

field: String

delta: i64

HKeys

Fields

key: String

HVals

Fields

key: String

HMGet

Fields

key: String

fields: Vec<String>

SAdd

Fields

key: String

members: Vec<String>

SRem

Fields

key: String

members: Vec<String>

SMembers

Fields

key: String

SIsMember

Fields

key: String

member: String

SCard

Fields

key: String

DbSize

Returns the key count for this shard.

Stats

Returns keyspace stats for this shard.

Snapshot

Triggers a snapshot write.

RewriteAof

Triggers an AOF rewrite (snapshot + truncate AOF).

FlushDb

Clears all keys from the keyspace.

Scan

Scans keys in the keyspace.

Fields

cursor: u64

count: usize

pattern: Option<String>

Trait Implementations

impl Debug for ShardRequest

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.