Struct WriteOp 

pub struct WriteOp {
    pub target: Target,
    pub doc: DocOp,
    pub epoch: Epoch,
    pub protocol: Protocol,
    pub trace: Option<TraceContext>,
    pub forward_headers: Vec<(String, String)>,
}

A single write operation against a resolved Target.

Carries the epoch the routing decision was derived from, stamped here so the sink (or a future migration-aware backend) can reject a stale-epoch write (docs/06 §2). For M1 the epoch is recorded and forwarded; stale-epoch rejection arrives with migration in M5.

Fields

target: Target

The physical destination of this operation.

doc: DocOp

The document operation to perform.

epoch: Epoch

The placement epoch this write was resolved against.

protocol: Protocol

The upstream wire protocol this op is dispatched over (per-request, docs/04 §7). Defaults to Protocol::Http1.

trace: Option<TraceContext>

The W3C trace context to forward downstream (traceparent), so the upstream’s spans join this request’s distributed trace.

forward_headers: Vec<(String, String)>

Client headers to relay verbatim to the upstream (the forwarding policy’s output). Applied before trace. Empty by default.

Implementations

impl WriteOp

pub fn new(target: Target, doc: DocOp, epoch: Epoch) -> Self

Constructs a write operation (defaulting to HTTP/1.1 upstream).

pub fn with_protocol(self, protocol: Protocol) -> Self

Sets the upstream protocol for this op (builder style).

pub fn with_trace(self, trace: Option<TraceContext>) -> Self

Sets the trace context to propagate downstream (builder style).

pub fn with_forward_headers(self, headers: Vec<(String, String)>) -> Self

Sets the client headers to relay verbatim to the upstream (builder style).

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

Formats the value using the given formatter.

impl Eq for WriteOp

impl PartialEq for WriteOp

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