Struct InFlightCancellation 

pub struct InFlightCancellation {
    pub worker_requests: Vec<CancelRequest>,
    pub declared_attempts: Vec<AttemptKey>,
}

Everything this node did to stop one run’s in-flight work.

Two lists because there are two execution paths and they are stopped by different means — asking a worker over its stream, and signalling a process this server owns. Kept apart rather than merged into one vocabulary: a worker ask is a question whose answer this node never sees, and a declared body’s stop is one the attempt itself witnesses, and calling both “cancel requests” would lose that difference exactly where an operator needs it.

Fields

worker_requests: Vec<CancelRequest>

One record per activity a WORKER was tracked as holding, including the ones that could not be asked.

declared_attempts: Vec<AttemptKey>

The declared bodies THIS SERVER was executing, now signalled. Each named attempt has had its cancellation raised; the attempt reports back only once its process group has been proven gone.

Implementations

impl InFlightCancellation

pub fn stopped_nothing(&self) -> bool

Whether this node stopped nothing at all — the common case for a run with no activity in flight, and not a failure.

Trait Implementations

impl Clone for InFlightCancellation

fn clone(&self) -> InFlightCancellation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InFlightCancellation

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

Formats the value using the given formatter.

impl Default for InFlightCancellation

fn default() -> InFlightCancellation

Returns the “default value” for a type.

impl Eq for InFlightCancellation

impl PartialEq for InFlightCancellation

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for InFlightCancellation