Struct OpContext 

pub struct OpContext {
    pub request_id: u64,
    pub cancel: CancelFlag,
    pub progress: Option<ProgressSink>,
    /* private fields */
}

Immutable-ish control context for one operation.

Fresh cancel token per operation — never reset a shared engine flag across ops.

Deadline uses a single absolute monotonic Instant; nested APIs should call Self::remaining rather than stacking independent timeouts.

Fields

request_id: u64

cancel: CancelFlag

progress: Option<ProgressSink>

Implementations

impl OpContext

pub fn new() -> Self

pub fn with_cancel(cancel: CancelFlag) -> Self

Create from an optional host cancel flag (cloned ownership of the same token).

pub fn from_optional_cancel(cancel: Option<CancelFlag>) -> Self

Build from an optional cancel flag, creating a fresh token when absent.

pub fn with_deadline_from_now(self, timeout: Duration) -> Self

pub fn with_absolute_deadline(self, at: Instant) -> Self

pub fn with_progress(self, sink: ProgressSink) -> Self

pub fn deadline(&self) -> Option<Instant>

pub fn remaining(&self) -> Option<Duration>

pub fn check(&self) -> Result<()>

Check cancel then deadline. Prefer cancel when both apply.

pub fn emit(&self, stage: &'static str, detail: impl Into<String>)

pub fn timeout_or(&self, fallback: Duration) -> Duration

Tokio-compatible timeout duration for the remaining budget (or fallback).

Trait Implementations

impl Clone for OpContext

fn clone(&self) -> OpContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OpContext

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

Formats the value using the given formatter.

impl Default for OpContext

fn default() -> Self

Returns the “default value” for a type.