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,
    },
    Pexpireat {
        key: String,
        timestamp_ms: 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,
    },
    SetBit {
        key: String,
        offset: u64,
        value: u8,
    },
    BitOp {
        op: u8,
        dest: String,
        keys: Vec<String>,
    },
    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

Pexpireat

PEXPIREAT key timestamp-ms — set expiry at an absolute Unix timestamp (ms).

Used to persist EXPIREAT and PEXPIREAT commands so that after recovery the expiry deadline is the same absolute point in time rather than being re-anchored to the moment of replay.

Fields

key: String

timestamp_ms: 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

SetBit

SETBIT key offset value. Replays the bit mutation verbatim.

Fields

key: String

offset: u64

value: u8

BitOp

BITOP op destkey key [key …]. Replays the bitwise operation.

op is stored as a raw byte: 0=AND, 1=OR, 2=XOR, 3=NOT.

Fields

op: u8

dest: String

keys: Vec<String>

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