Struct WorkflowTaskCleanupShard 

pub struct WorkflowTaskCleanupShard { /* private fields */ }

Stable assignment of tenants across cleanup processes.

Implementations

impl WorkflowTaskCleanupShard

pub fn new(index: u32, count: NonZeroU32) -> Result<Self, WorkflowStoreError>

Creates one zero-based shard.

Errors

Rejects an index outside the shard count.

pub const fn index(self) -> u32

Zero-based shard index.

pub const fn count(self) -> u32

Total configured shards.

pub fn owns(self, tenant_id: &WorkflowTenantId) -> bool

Returns whether this shard owns a tenant under the stable hash.

Trait Implementations

impl Clone for WorkflowTaskCleanupShard

fn clone(&self) -> WorkflowTaskCleanupShard

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for WorkflowTaskCleanupShard

impl Debug for WorkflowTaskCleanupShard

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

Formats the value using the given formatter.

impl Eq for WorkflowTaskCleanupShard

impl PartialEq for WorkflowTaskCleanupShard

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for WorkflowTaskCleanupShard