Enum DocOp 

pub enum DocOp {
    Index {
        id: Option<String>,
        routing: Option<String>,
        body: Bytes,
    },
    Create {
        id: Option<String>,
        routing: Option<String>,
        body: Bytes,
    },
    Update {
        id: String,
        routing: Option<String>,
        body: Bytes,
    },
    Delete {
        id: String,
        routing: Option<String>,
    },
}

A document-level operation: the already-transformed body plus the constructed id/routing (the tenancy rewrite has already run, docs/04).

Not #[non_exhaustive]: every sink must handle every op kind, so adding one should force sinks to be updated.

Variants

Index

Index (create-or-replace) a document.

Fields

id: Option<String>

The constructed document id, or None to let OpenSearch auto-assign.

routing: Option<String>

The _routing value (the partition id), if routing is enabled.

body: Bytes

The transformed document body (injected fields applied).

Create

Create a document, failing with a conflict if the id already exists (op_type=create). Distinct from DocOp::Index so the sink can target the _create endpoint and surface the 409 (docs/04 §3).

Fields

id: Option<String>

The constructed document id, or None to let OpenSearch auto-assign.

routing: Option<String>

The _routing value (the partition id), if routing is enabled.

body: Bytes

The transformed document body (injected fields applied).

Update

Partial-update a document by id (_update): the body carries the already-transformed doc/upsert/script (docs/04 §3).

Fields

id: String

The constructed document id to update.

routing: Option<String>

The _routing value, if routing is enabled.

body: Bytes

The transformed update body (injected into doc/upsert).

Delete

Delete a document by id.

Fields

id: String

The constructed document id to delete.

routing: Option<String>

The _routing value, if routing is enabled.

Trait Implementations

impl Clone for DocOp

fn clone(&self) -> DocOp

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DocOp

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

Formats the value using the given formatter.

impl Eq for DocOp

impl PartialEq for DocOp

fn eq(&self, other: &DocOp) -> 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 DocOp