Enum AofRecord 

pub enum AofRecord {
    Set {
        key: String,
        value: Bytes,
        expire_ms: i64,
    },
    Del {
        key: String,
    },
    Expire {
        key: String,
        seconds: u64,
    },
    LPush {
        key: String,
        values: Vec<Bytes>,
    },
    RPush {
        key: String,
        values: Vec<Bytes>,
    },
    LPop {
        key: String,
    },
    RPop {
        key: String,
    },
    LSet {
        key: String,
        index: i64,
        value: Bytes,
    },
    LTrim {
        key: String,
        start: i64,
        stop: i64,
    },
    LInsert {
        key: String,
        before: bool,
        pivot: Bytes,
        value: Bytes,
    },
    LRem {
        key: String,
        count: i64,
        value: Bytes,
    },
    ZAdd {
        key: String,
        members: Vec<(f64, String)>,
    },
    ZRem {
        key: String,
        members: Vec<String>,
    },
    Persist {
        key: String,
    },
    Pexpire {
        key: String,
        milliseconds: u64,
    },
    Incr {
        key: String,
    },
    Decr {
        key: String,
    },
    HSet {
        key: String,
        fields: Vec<(String, Bytes)>,
    },
    HDel {
        key: String,
        fields: Vec<String>,
    },
    HIncrBy {
        key: String,
        field: String,
        delta: i64,
    },
    SAdd {
        key: String,
        members: Vec<String>,
    },
    SRem {
        key: String,
        members: Vec<String>,
    },
    IncrBy {
        key: String,
        delta: i64,
    },
    DecrBy {
        key: String,
        delta: i64,
    },
    Append {
        key: String,
        value: Bytes,
    },
    SetRange {
        key: String,
        offset: usize,
        value: Bytes,
    },
    Rename {
        key: String,
        newkey: String,
    },
    Copy {
        source: String,
        destination: String,
        replace: bool,
    },
}

A single mutation record stored in the AOF.

Variants

Set

SET key value [expire_ms]. expire_ms is -1 for no expiration.

Fields

key: String

value: Bytes

expire_ms: i64

Del

DEL key.

Fields

key: String

Expire

EXPIRE key seconds.

Fields

key: String

seconds: u64

LPush

LPUSH key value [value …].

Fields

key: String

values: Vec<Bytes>

RPush

RPUSH key value [value …].

Fields

key: String

values: Vec<Bytes>

LPop

LPOP key.

Fields

key: String

RPop

RPOP key.

Fields

key: String

LSet

LSET key index element.

Fields

key: String

index: i64

value: Bytes

LTrim

LTRIM key start stop.

Fields

key: String

start: i64

stop: i64

LInsert

LINSERT key BEFORE|AFTER pivot element.

Fields

key: String

before: bool

pivot: Bytes

value: Bytes

LRem

LREM key count element.

Fields

key: String

count: i64

value: Bytes

ZAdd

ZADD key score member [score member …].

Fields

key: String

members: Vec<(f64, String)>

ZRem

ZREM key member [member …].

Fields

key: String

members: Vec<String>

Persist

PERSIST key — remove expiration.

Fields

key: String

Pexpire

PEXPIRE key milliseconds.

Fields

key: String

milliseconds: u64

Incr

INCR key.

Fields

key: String

Decr

DECR key.

Fields

key: String

HSet

HSET key field value [field value …].

Fields

key: String

fields: Vec<(String, Bytes)>

HDel

HDEL key field [field …].

Fields

key: String

fields: Vec<String>

HIncrBy

HINCRBY key field delta.

Fields

key: String

field: String

delta: i64

SAdd

SADD key member [member …].

Fields

key: String

members: Vec<String>

SRem

SREM key member [member …].

Fields

key: String

members: Vec<String>

IncrBy

INCRBY key delta.

Fields

key: String

delta: i64

DecrBy

DECRBY key delta.

Fields

key: String

delta: i64

Append

APPEND key value.

Fields

key: String

value: Bytes

SetRange

SETRANGE key offset value.

Fields

key: String

offset: usize

value: Bytes

Rename

RENAME key newkey.

Fields

key: String

newkey: String

Copy

COPY source destination [REPLACE].

Fields

source: String

destination: String

replace: bool

Implementations

impl AofRecord

pub fn to_bytes(&self) -> Result<Vec<u8>, FormatError>

Serializes this record into a byte vector (tag + payload, no CRC).

pub fn from_bytes(data: &[u8]) -> Result<Self, FormatError>

Deserializes a record from its binary payload (tag byte + fields, no CRC).

The format is the same as to_bytes(). CRC validation is the caller’s responsibility (done by the AOF recovery reader before this is called).

Trait Implementations

impl Clone for AofRecord

fn clone(&self) -> AofRecord

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AofRecord

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

Formats the value using the given formatter.

impl PartialEq for AofRecord

fn eq(&self, other: &AofRecord) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for AofRecord