Enum VectorResolvedMutation 

pub enum VectorResolvedMutation {
    Delete {
        surrogate: Surrogate,
        old_payload: Vec<u8>,
    },
    Update {
        surrogate: Surrogate,
        new_vector: Option<Vec<f32>>,
        merged_payload: Vec<u8>,
        old_payload: Vec<u8>,
    },
    Upsert {
        surrogate: Surrogate,
        pk_bytes: Vec<u8>,
        vector: Vec<f32>,
        payload: Vec<u8>,
        old_payload: Option<Vec<u8>>,
    },
}

One row mutation a resolved vector-primary write applies.

Every variant carries the sidecar bytes the resolve read for its row — the apply’s drift check. A row’s sidecar is its zerompk TAGGED payload map and is never empty once written, so Vec::new() on Delete / Update names a bound node with no sidecar row behind it, and the apply compares it against an absent sidecar.

Variants

Delete

Remove surrogate’s HNSW node, bitmap entries, and sidecar.

Fields

surrogate: Surrogate

old_payload: Vec<u8>

Sidecar bytes the resolve read; the node must still be bound and hold exactly these bytes.

Update

Rewrite surrogate’s row: a new_vector rebuilds the HNSW node under the same surrogate, merged_payload replaces the sidecar and moves the bitmap entries.

Fields

surrogate: Surrogate

new_vector: Option<Vec<f32>>

merged_payload: Vec<u8>

The full post-image sidecar, already merged and lower-cased, in the sidecar’s own zerompk TAGGED encoding.

old_payload: Vec<u8>

Sidecar bytes the resolve read; see Delete::old_payload.

Upsert

Store a whole row under surrogate, replacing any existing one.

Fields

surrogate: Surrogate

pk_bytes: Vec<u8>

UTF-8 of the declared primary-key value. Followers bind the leader-assigned surrogate to this exact key.

vector: Vec<f32>

payload: Vec<u8>

The sidecar to store, in its own zerompk TAGGED encoding.

old_payload: Option<Vec<u8>>

None requires the surrogate to still be unbound; Some(bytes) requires a bound node whose sidecar holds exactly bytes.

Implementations

impl VectorResolvedMutation

pub fn surrogate(&self) -> Surrogate

The surrogate this one mutation targets.

pub fn stored_vector(&self) -> Option<&[f32]>

The vector this mutation stores, when it stores one.

Trait Implementations

impl Clone for VectorResolvedMutation

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for VectorResolvedMutation

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for VectorResolvedMutation

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'__msgpack_de> FromMessagePack<'__msgpack_de> for VectorResolvedMutation

fn read<R: Read<'__msgpack_de>>(reader: &mut R) -> Result<Self, Error>

where Self: Sized,

Reads the MessagePack representation of this value from the provided reader.

impl PartialEq for VectorResolvedMutation

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for VectorResolvedMutation

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for VectorResolvedMutation

impl ToMessagePack for VectorResolvedMutation

fn write<W: Write>(&self, writer: &mut W) -> Result<(), Error>

Writes the MessagePack representation of this value into the provided writer.

fn write_slice<W>(values: &[Self], writer: &mut W) -> Result<(), Error>

where W: Write, Self: Sized,

Writes the MessagePack representation of a slice of values into the provided writer.

fn size_hint(&self) -> Option<TrustedSizeHint>

Returns a trusted upper bound for the number of bytes written by the next call to Self::write, or None when it cannot be determined cheaply.

fn max_size() -> Option<TrustedSizeHint>

where Self: Sized,

Returns a trusted upper bound valid for every value of this type.