Struct WorkerRevocationManager 

pub struct WorkerRevocationManager { /* private fields */ }

Thread-safe revocation manager for workers

Implementations

impl WorkerRevocationManager

pub fn new() -> Self

Create a new worker revocation manager

pub fn revoke(&self, task_id: Uuid, mode: RevocationMode)

Revoke a task by ID

pub fn revoke_with_request(&self, request: RevocationRequest)

Revoke a task with a full request

pub fn revoke_by_pattern(&self, pattern: &str, mode: RevocationMode)

Revoke by pattern

pub fn bulk_revoke(&self, task_ids: &[Uuid], mode: RevocationMode)

Bulk revoke multiple tasks

pub fn is_revoked(&self, task_id: Uuid) -> bool

Check if a task is revoked by ID

pub fn check_revocation( &self, task_id: Uuid, task_name: &str, ) -> RevocationResult

Check revocation status (by ID and pattern)

pub fn mark_terminated(&self, task_id: Uuid)

Mark a task as terminated

pub fn is_terminated(&self, task_id: Uuid) -> bool

Check if a task has been terminated

pub fn unrevoke(&self, task_id: Uuid)

Remove revocation for a task ID

pub fn cleanup_expired(&self)

Clean up expired revocations

pub fn revoked_ids(&self) -> Vec<Uuid>

Get all revoked task IDs

pub fn revoked_count(&self) -> usize

Get count of revoked tasks

pub fn export_state(&self) -> RevocationState

Export state for persistence

pub fn import_state(&self, state: RevocationState)

Import state from persistence

pub fn clear(&self)

Clear all revocations

Trait Implementations

impl Clone for WorkerRevocationManager

fn clone(&self) -> WorkerRevocationManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerRevocationManager

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

Formats the value using the given formatter.

impl Default for WorkerRevocationManager

fn default() -> WorkerRevocationManager

Returns the “default value” for a type.