Struct WorkflowTaskCleanupSupervisorConfig 

pub struct WorkflowTaskCleanupSupervisorConfig { /* private fields */ }

Validated bounds and timing for automatic terminal Task cleanup.

Implementations

impl WorkflowTaskCleanupSupervisorConfig

pub fn new( shard: WorkflowTaskCleanupShard, retention: WorkflowTaskRetention, lease_duration: LeaseDuration, heartbeat_interval: Duration, ) -> Result<Self, WorkflowStoreError>

Creates conservative cleanup timing and work bounds.

Errors

Rejects a zero heartbeat or one not shorter than the lease.

pub const fn with_work_limits( self, discovery_limit: WorkflowTenantListLimit, max_concurrency: NonZeroUsize, cleanup_limit: WorkflowTaskCleanupLimit, max_batches_per_tenant: NonZeroU32, ) -> Self

Sets bounded discovery, concurrency, batch size, and work per claim.

pub fn with_intervals( self, scan_interval: Duration, error_backoff: Duration, ) -> Result<Self, WorkflowStoreError>

Sets successful-scan and error delays.

Errors

Rejects zero durations to prevent hot loops.

Trait Implementations

impl Clone for WorkflowTaskCleanupSupervisorConfig

fn clone(&self) -> WorkflowTaskCleanupSupervisorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for WorkflowTaskCleanupSupervisorConfig

impl Debug for WorkflowTaskCleanupSupervisorConfig

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

Formats the value using the given formatter.

impl Eq for WorkflowTaskCleanupSupervisorConfig

impl PartialEq for WorkflowTaskCleanupSupervisorConfig

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for WorkflowTaskCleanupSupervisorConfig