Struct TaskSharder 

pub struct TaskSharder { /* private fields */ }

Task-state sharding by stable task-ID hash (P2-9).

A 1000-agent fleet cannot keep every task in one store; this maps each task id to a shard so state is distributed deterministically and collocated lookups stay local.

Implementations

impl TaskSharder

pub fn new(num_shards: usize) -> Self

A sharder over num_shards shards (clamped to at least 1).

pub fn shard(&self, task_id: &str) -> usize

The shard index (0-based) responsible for task_id.

pub fn shards<'a>( &self, task_ids: impl IntoIterator<Item = &'a str>, ) -> Vec<usize>

Shard assignments for many task ids, preserving order.

pub fn num_shards(&self) -> usize

The number of shards.

Trait Implementations

impl Clone for TaskSharder

fn clone(&self) -> TaskSharder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for TaskSharder

impl Debug for TaskSharder

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

Formats the value using the given formatter.