Enum ShardState 

pub enum ShardState {
    Provisioning,
    Active,
    Draining,
    Stopped,
}

State of a shard in the mapper.

Variants

Provisioning

Shard is being provisioned: id allocated and metrics collector in place, but select_shard must not route to it yet because upstream workers (drain / batch) have not been spawned. Caller transitions to Active via activate once the workers are ready. Closes the race where a freshly-added shard accepted producer pushes before any consumer existed.

Active

Shard is active and accepting producers.

Draining

Shard is draining (no new producers, waiting for empty).

Stopped

Shard is stopped and can be removed.

Trait Implementations

impl Clone for ShardState

fn clone(&self) -> ShardState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ShardState

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

Formats the value using the given formatter.

impl PartialEq for ShardState

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for ShardState

impl Eq for ShardState

impl StructuralPartialEq for ShardState