Struct StationScheduler 

pub struct StationScheduler {
    pub advanced_ticks: u64,
}

Basic in-process station scheduler.

Fields

advanced_ticks: u64

Total station ticks advanced by this scheduler.

Implementations

impl StationScheduler

pub fn advance_all(&mut self, stations: &mut StationSet)

Advances every station by one tick.

pub fn plan_loaded( &self, stations: &StationSet, samples: &[StationLoadSample], config: StationScheduleConfig, ) -> StationSchedulePlan

Plans a bounded station advancement pass from load samples.

pub fn plan_loaded_into<'a>( &self, stations: &StationSet, samples: &[StationLoadSample], config: StationScheduleConfig, scratch: &'a mut StationScheduleScratch, ) -> StationScheduleView<'a>

Plans into caller-owned storage and returns a borrowed deterministic top-k view.

pub fn advance_loaded( &mut self, stations: &mut StationSet, samples: &[StationLoadSample], config: StationScheduleConfig, ) -> StationSchedulePlan

Advances a bounded set of high-load stations by one tick each.

pub fn advance_loaded_into<'a>( &mut self, stations: &mut StationSet, samples: &[StationLoadSample], config: StationScheduleConfig, scratch: &'a mut StationScheduleScratch, ) -> StationScheduleView<'a>

Advances a bounded top-k set using reusable caller-owned scheduling storage.

pub fn drain_ready_events( &mut self, stations: &StationSet, router: &mut EventRouter, ) -> Result<Vec<StationEvent>, EventRouterError>

Drains router events ready for each station’s current tick.

pub fn drain_ready_events_into( &mut self, stations: &StationSet, router: &mut EventRouter, events: &mut Vec<StationEvent>, ) -> Result<(), EventRouterError>

Drains all Station-ready events into reusable caller-owned output.

Trait Implementations

impl Clone for StationScheduler

fn clone(&self) -> StationScheduler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StationScheduler

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

Formats the value using the given formatter.

impl Default for StationScheduler

fn default() -> StationScheduler

Returns the “default value” for a type.