Struct ProxyScheduler 

pub struct ProxyScheduler { /* private fields */ }

Proxy task scheduler.

Implementations

impl ProxyScheduler

pub fn new(config: ProxySchedulerConfig) -> Self

Create a new scheduler with the given config.

pub fn submit( &mut self, source: &str, dest: &str, estimated_secs: f64, ) -> Option<u64>

Submit a task to the scheduler queue. Returns the assigned task id.

pub fn complete_one(&mut self)

Advance running tasks — mark the first running task as complete. In a real implementation this would be driven by async I/O callbacks.

pub fn running_count(&self) -> usize

Return the number of currently running tasks.

pub fn queued_count(&self) -> usize

Return the number of queued (pending) tasks.

pub fn stats(&self) -> &ProxySchedulerStats

Return a reference to scheduler statistics.

pub fn record_elapsed(&mut self, secs: f64)

Record elapsed time for statistics calculation.

Trait Implementations

impl Debug for ProxyScheduler

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

Formats the value using the given formatter.