Enum UpdateOperation 

pub enum UpdateOperation {
    PointOperation(PointOperations),
    VectorOperation(VectorOperations),
    PayloadOperation(PayloadOps),
    FieldIndexOperation(FieldIndexOperations),
    VectorNameOperation(VectorNameOperations),
}

Variants

PointOperation(PointOperations)

VectorOperation(VectorOperations)

PayloadOperation(PayloadOps)

FieldIndexOperation(FieldIndexOperations)

VectorNameOperation(VectorNameOperations)

Implementations

impl CollectionUpdateOperations

pub fn operation_name(&self) -> &'static str

A stable, human-readable name for the operation, including its inner variant.

Used for audit logging and for reporting slow operations during WAL recovery.

impl CollectionUpdateOperations

pub fn is_upsert_points(&self) -> bool

pub fn is_delete_points(&self) -> bool

pub fn point_ids(&self) -> Option<Vec<ExtendedPointId>>

pub fn consumes_quota(&self) -> bool

Whether applying this operation grows what the node holds, which is what [crate::quota] caps.

Only deleting whole points is excluded, and it has to be: it is the one way out of a node that has hit its limit. Deleting a vector or a payload key is not — copy-on-write rewrites the point to drop a field, so it grows storage before anything is reclaimed.

Shard-transfer syncs are excluded as well: a transfer is sized up once before it starts, and refusing its batches partway would abandon work that is nearly done, only for the whole transfer to be retried from the beginning.

pub fn upsert_point_ids(&self) -> Option<Vec<ExtendedPointId>>

List point IDs that can be created during the operation. Do not list IDs that are deleted or modified.

pub fn retain_point_ids<F>(&mut self, filter: F)

where F: Fn(&ExtendedPointId) -> bool,

pub fn retain_vector_names(&mut self, valid: &HashSet<String>)

Drop named-vector references to vector names not in valid.

Used during WAL replay: a historical operation may reference a vector name that was since removed by delete_named_vector. Without this, such an operation fails segment validation (VectorNameNotExists) and is dropped wholesale on reload, taking its points with it. Stripping the dead names lets the rest of the operation apply, matching the live outcome (the point survives, just without the deleted vector).

This does not touch VectorNameOperation responsible for creating/deleting a named vector.

Only affects the named-vector variants; the default (unnamed) vector is left untouched.

Note: this is best-effort. Stripping a vector from an early operation silently changes the behavior of a later operation that depended on it (e.g. a has_vector filter or UpdateVectors), so the replayed timeline can still diverge from the live one. Tracked in https://github.com/qdrant/qdrant/issues/9386.

pub fn created_vector_name(&self) -> Option<&String>

If this operation creates a named vector, return the name it introduces.

Used during WAL replay to grow the set of valid vector names: a historical CreateVectorName must make its name valid for the operations that follow it in the WAL, otherwise a later upsert referencing it would be wrongly stripped by Self::retain_vector_names.

Trait Implementations

impl Clone for CollectionUpdateOperations

fn clone(&self) -> CollectionUpdateOperations

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CollectionUpdateOperations

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CollectionUpdateOperations

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Hash for CollectionUpdateOperations

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl IntoDiscriminant for CollectionUpdateOperations

type Discriminant = CollectionUpdateOperationsDiscriminants

Enum listing the same variants as this enum but without any data fields

fn discriminant(&self) -> Self::Discriminant

impl PartialEq for CollectionUpdateOperations

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for CollectionUpdateOperations

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 CollectionUpdateOperations