Struct SplitExecutor 

pub struct SplitExecutor { /* private fields */ }

Stateful conservative split planner and executor.

Implementations

impl SplitExecutor

pub fn new(config: SplitSchedulerConfig) -> Self

Creates an executor without allocating planning or execution output.

pub fn plan<'a>( &'a mut self, samples: &[StationLoadSample], current_tick: Tick, ) -> SplitScheduleView<'a>

Plans into retained storage and returns the active borrowed schedule.

Examples found in repository

examples/maintenance_flow.rs (line 15)

fn main() {
    let mut stations = StationSet::default();
    let indexes = StationIndexSet::default();
    let mut router = EventRouter::default();

    let mut sampler = LoadSampler::default();
    let load = sampler.sample(&stations, &indexes, &router, &[]);

    let mut splits = SplitExecutor::default();
    let schedule = splits.plan(load, Tick::new(1));
    let mut station_execution = StationExecutor::default();
    let advances = station_execution
        .advance_loaded(&mut stations, load)
        .stations_selected;
    let ready_events = station_execution
        .drain_ready_events(&stations, &mut router)
        .expect("empty event drain should work")
        .len();

    println!("samples={}", load.len());
    println!("split_actions={}", schedule.actions.len());
    println!("station_advances={advances}");
    println!("ready_events={ready_events}");
}

pub fn planned(&self) -> SplitScheduleView<'_>

Returns the current planned schedule without executing it.

pub fn execute_planned<'a>( &'a mut self, stations: &mut StationSet, indexes: &mut StationIndexSet, ownership: &mut CellOwnershipTable, ) -> Result<SplitScheduleExecutionView<'a>, SplitScheduleExecutionError>

Executes the current plan and records successful actions for cooldown.

pub fn retained_capacities(&self) -> SplitExecutorCapacities

Returns retained planning and execution capacities.

Trait Implementations

impl Clone for SplitExecutor

fn clone(&self) -> SplitExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SplitExecutor

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

Formats the value using the given formatter.

impl Default for SplitExecutor

fn default() -> Self

Returns the “default value” for a type.