Struct WorkflowTaskCleanupSupervisor 

pub struct WorkflowTaskCleanupSupervisor<S> { /* private fields */ }

Discovers, shards, and cleans terminal Tasks with bounded concurrency.

Implementations

impl<S> WorkflowTaskCleanupSupervisor<S>

where S: WorkflowTaskRetentionStore + 'static,

pub fn new( store: Arc<S>, owner: WorkerId, config: WorkflowTaskCleanupSupervisorConfig, ) -> Self

Creates a cleanup supervisor with system timers.

pub fn with_sleeper(self, sleeper: Arc<dyn WorkflowWorkerSleeper>) -> Self

Overrides sleeping for deterministic runtimes and tests.

pub fn with_metrics(self, metrics: WorkflowTaskCleanupSupervisorMetrics) -> Self

Uses shared lock-free health metrics.

pub fn with_observer( self, observer: Arc<dyn WorkflowTaskCleanupObserver>, ) -> Self

Attaches a non-blocking low-cardinality outcome observer.

pub const fn metrics(&self) -> &WorkflowTaskCleanupSupervisorMetrics

Returns this supervisor’s health metrics.

pub async fn scan_once( &self, ) -> Result<WorkflowTaskCleanupSupervisorReport, WorkflowStoreError>

Performs one stable paginated discovery and bounded cleanup scan.

Per-tenant failures are isolated. Discovery failure aborts the scan.

Errors

Returns a typed store error when tenant discovery fails.

pub async fn run( &self, shutdown: &CancellationToken, ) -> WorkflowTaskCleanupSupervisorReport

Continuously rescans until cancellation.

A scan already in progress is drained before shutdown.

Trait Implementations

impl<S> Debug for WorkflowTaskCleanupSupervisor<S>

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

Formats the value using the given formatter.