Struct WorkScheduler 

pub struct WorkScheduler { /* private fields */ }

Work scheduler for distributing items to agents

Implementations

impl WorkScheduler

pub fn new(strategy: SchedulingStrategy, items: Vec<Value>) -> Self

Create a new scheduler with the specified strategy

pub async fn next_item(&self) -> Option<WorkItem>

Get the next work item according to the scheduling strategy

pub async fn next_batch(&self, batch_size: usize) -> Vec<WorkItem>

Get a batch of work items

pub async fn remaining_count(&self) -> usize

Get remaining item count

pub async fn processed_count(&self) -> usize

Get processed item count

pub async fn is_complete(&self) -> bool

Check if all items have been scheduled

pub async fn create_channel_scheduler( self, buffer_size: usize, ) -> (Sender<WorkItem>, Receiver<WorkItem>)

Create a channel-based scheduler for async distribution

pub async fn reset(&self, items: Vec<Value>)

Reset the scheduler with new items