Enum KvCommand 

pub enum KvCommand {
    Put {
        model: CollectionModel,
        collection: String,
        key: String,
        value: Value,
        ttl_ms: Option<u64>,
        tags: Vec<String>,
        if_not_exists: bool,
    },
    InvalidateTags {
        collection: String,
        tags: Vec<String>,
    },
    Get {
        model: CollectionModel,
        collection: String,
        key: String,
    },
    Unseal {
        collection: String,
        key: String,
        version: Option<i64>,
    },
    Rotate {
        collection: String,
        key: String,
        value: Value,
        tags: Vec<String>,
    },
    History {
        collection: String,
        key: String,
    },
    List {
        model: CollectionModel,
        collection: String,
        prefix: Option<String>,
        limit: Option<usize>,
        offset: usize,
    },
    Purge {
        collection: String,
        key: String,
    },
    Watch {
        model: CollectionModel,
        collection: String,
        key: String,
        prefix: bool,
        from_lsn: Option<u64>,
    },
    Delete {
        model: CollectionModel,
        collection: String,
        key: String,
    },
    Incr {
        model: CollectionModel,
        collection: String,
        key: String,
        by: i64,
        ttl_ms: Option<u64>,
    },
    Cas {
        model: CollectionModel,
        collection: String,
        key: String,
        expected: Option<Value>,
        new_value: Value,
        ttl_ms: Option<u64>,
    },
}

KV verb commands: KV PUT key = value [EXPIRE n] [IF NOT EXISTS], KV GET key, KV DELETE key

Variants

Put

Fields

model: CollectionModel

collection: String

key: String

value: Value

ttl_ms: Option<u64>

TTL in milliseconds (from EXPIRE clause)

tags: Vec<String>

if_not_exists: bool

InvalidateTags

Fields

collection: String

tags: Vec<String>

Get

Fields

model: CollectionModel

collection: String

key: String

Unseal

Fields

collection: String

key: String

version: Option<i64>

Rotate

Fields

collection: String

key: String

value: Value

tags: Vec<String>

History

Fields

collection: String

key: String

List

Fields

model: CollectionModel

collection: String

prefix: Option<String>

limit: Option<usize>

offset: usize

Purge

Fields

collection: String

key: String

Watch

Fields

model: CollectionModel

collection: String

key: String

prefix: bool

from_lsn: Option<u64>

Delete

Fields

model: CollectionModel

collection: String

key: String

Incr

KV INCR key [BY n] [EXPIRE dur] — atomic increment; negative by = decrement.

Fields

model: CollectionModel

collection: String

key: String

by: i64

Step value; negative for DECR. Defaults to 1.

ttl_ms: Option<u64>

Cas

KV CAS key EXPECT <expected|NULL> SET <new> [EXPIRE dur] — compare-and-set.

expected = None means EXPECT NULL (key must be absent).

Fields

model: CollectionModel

collection: String

key: String

expected: Option<Value>

The value the caller expects to be current; None = key must be absent.

new_value: Value

ttl_ms: Option<u64>

Trait Implementations

impl Clone for KvCommand

fn clone(&self) -> KvCommand

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KvCommand

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

Formats the value using the given formatter.