Struct Scheduler 

pub struct Scheduler { /* private fields */ }

Download scheduler

Implementations

impl Scheduler

pub fn new(config: SchedulerConfig) -> Self

Create a new scheduler

pub fn enqueue(&self, fragment: PrioritizedFragment)

Enqueue a fragment for download

pub fn enqueue_many( &self, fragments: impl IntoIterator<Item = PrioritizedFragment>, )

Enqueue multiple fragments

pub async fn next(&self) -> Option<(PrioritizedFragment, SchedulerPermit<'_>)>

Get next fragment to download

pub async fn record_success(&self, bytes: u64, duration: Duration)

Record completed download

pub fn record_failure(&self)

Record failed download

pub fn bandwidth(&self) -> &BandwidthMonitor

Get bandwidth monitor

pub fn queue_len(&self) -> usize

Get queue length

pub fn active(&self) -> u64

Get active downloads

pub fn completed(&self) -> u64

Get completed downloads

pub fn failed(&self) -> u64

Get failed downloads

pub async fn should_throttle(&self) -> bool

Check if should reduce concurrency (bandwidth dropping)

pub async fn stats(&self) -> SchedulerStats

Get scheduler statistics

pub fn clear(&self)

Clear the queue

pub fn update_priority(&self, fragment_id: &FragmentId, priority: Priority)

Update priority of queued fragment