Struct CancelOperation 

pub struct CancelOperation<'a, Admission = Waiting, Termination = TerminationUnbounded, Target = TaskTarget> { /* private fields */ }

A task-cancellation operation with independent queue and termination-wait policy.

fail_fast changes only command-queue admission. termination_timeout changes only the later wait for logical terminal cleanup. The two settings can be applied in either order.

Implementations

impl<'a, Termination, Target> CancelOperation<'a, Waiting, Termination, Target>

pub fn fail_fast(self) -> CancelOperation<'a, FailFast, Termination, Target>

Immediate admission to the required management queue.

impl<'a, Admission, Target> CancelOperation<'a, Admission, TerminationUnbounded, Target>

pub fn termination_timeout( self, wait_for: Duration, ) -> CancelOperation<'a, Admission, TerminationTimed, Target>

Deadline for this caller’s logical terminal-cleanup wait.

Queue admission and the cancellation claim are outside this deadline. A timeout does not undo an already committed cancellation.

impl<Target> CancelOperation<'_, Waiting, TerminationUnbounded, Target>

where Target: Into<TaskTarget>,

pub async fn execute(self) -> Result<bool, RuntimeError>

Cancellation claim after waiting queue admission and logical terminal cleanup.

Errors

• Returns RuntimeError::ShuttingDown when runtime intake is closed;
• RuntimeError::ResourceLimitReached when the controller identity-operation budget is exhausted.

impl<Target> CancelOperation<'_, FailFast, TerminationUnbounded, Target>

where Target: Into<TaskTarget>,

pub async fn execute(self) -> Result<bool, RuntimeError>

Cancellation claim after immediate queue admission and unbounded terminal cleanup.

Errors

• Returns RuntimeError::ShuttingDown when runtime intake is closed;
• RuntimeError::CommandQueueFull when the required management queue has no capacity;
• RuntimeError::ResourceLimitReached when the controller identity-operation budget is exhausted.

impl<Target> CancelOperation<'_, Waiting, TerminationTimed, Target>

where Target: Into<TaskTarget>,

pub async fn execute(self) -> Result<bool, RuntimeError>

Cancellation claim after waiting queue admission and bounded terminal cleanup.

Errors

• Returns RuntimeError::ShuttingDown when runtime intake is closed;
• RuntimeError::TaskTerminationTimeout when registered task cleanup exceeds this caller’s deadline;
• RuntimeError::ResourceLimitReached when the controller identity-operation budget is exhausted.

impl<Target> CancelOperation<'_, FailFast, TerminationTimed, Target>

where Target: Into<TaskTarget>,

pub async fn execute(self) -> Result<bool, RuntimeError>

Cancellation claim after immediate queue admission and bounded terminal cleanup.

Errors

• Returns RuntimeError::ShuttingDown when runtime intake is closed;
• RuntimeError::CommandQueueFull when the required management queue has no capacity;
• RuntimeError::TaskTerminationTimeout when registered task cleanup exceeds this caller’s deadline;
• RuntimeError::ResourceLimitReached when the controller identity-operation budget is exhausted.

Trait Implementations

impl<Admission, Termination, Target> Debug for CancelOperation<'_, Admission, Termination, Target>

where Admission: Debug, Termination: Debug,

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

Formats the value using the given formatter.