Enum WriteOp 

#[non_exhaustive]
pub enum WriteOp {
    KvPut {
        key: Vec<u8>,
        value: Vec<u8>,
    },
    KvDelete {
        key: Vec<u8>,
    },
    VectorUpsert {
        index: String,
        id: Vec<u8>,
        embedding: Vec<f32>,
        metadata: Value,
    },
    GraphNode {
        graph: String,
        id: Vec<u8>,
        label: String,
        props: Value,
        index_kind: String,
    },
    GraphEdge {
        graph: String,
        src: Vec<u8>,
        dst: Vec<u8>,
        rel: String,
        props: Value,
    },
}

One operation in an atomic_write batch.

All variants must commit together or all roll back. The backend translates each variant to its native command (HSET, FT.SUGADD, GRAPH.QUERY MERGE on Moon).

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

KvPut

KV put at this key/value pair.

Fields

key: Vec<u8>

value: Vec<u8>

KvDelete

KV tombstone (logical delete; physical removal at consolidation time).

Fields

key: Vec<u8>

VectorUpsert

Vector index upsert. index is the vector index name (e.g., “chunk_emb”).

Fields

index: String

id: Vec<u8>

embedding: Vec<f32>

metadata: Value

GraphNode

Graph node upsert.

index_kind names the vector/keyword FT index this node’s content lives in (e.g. "entities", "facts") — backends that register a key_to_node mapping for graph-expanded search (Moon’s FT.NAVIGATE) need it to build the node’s _key against the RIGHT index instead of assuming every graph node is an entity. Defaults to "entities" on deserialize (pre-index_kind callers / WAL replay) since entities were the only graph-registered kind before this field existed.

Fields

graph: String

id: Vec<u8>

label: String

props: Value

index_kind: String

GraphEdge

Graph edge upsert.

Fields

graph: String

src: Vec<u8>

dst: Vec<u8>

rel: String

props: Value

Trait Implementations

impl Clone for WriteOp

fn clone(&self) -> WriteOp

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WriteOp

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WriteOp

fn deserialize<__D>( __deserializer: __D, ) -> Result<WriteOp, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WriteOp

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.