Struct RuntimeOperatorStageGuard 

pub struct RuntimeOperatorStageGuard { /* private fields */ }

Exactly-once Started/terminal guardian for one operator substage.

Implementations

impl RuntimeOperatorStageGuard

pub fn start( observation: RuntimeObservationHandle, plan_execution_id: Option<PlanExecutionId>, parent_span_id: Option<RuntimeSpanId>, stage_kind: RuntimeOperatorStageKind, identity: RuntimeOperatorStageIdentity, ) -> Self

Emits Started immediately and returns a guard that emits one terminal.

pub fn finish(self, output_rows: Option<u64>, output_bytes: Option<u64>)

Records successful completion with optional output facts.

pub fn finish_with_strategy_label( self, strategy_label: impl Into<String>, output_rows: Option<u64>, output_bytes: Option<u64>, )

Attach a native fit outcome known only after the operation completes.

pub fn fail(self, error: &QueryError)

Records structured failure or cancellation from a native error.

pub fn cancel(self)

Records cooperative cancellation without a full error object.

Trait Implementations

impl Debug for RuntimeOperatorStageGuard

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

Formats the value using the given formatter.

impl Drop for RuntimeOperatorStageGuard

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.