Struct TestScheduler 

pub struct TestScheduler {
    pub duration_history: HashMap<String, Vec<u64>>,
    pub default_duration_ms: u64,
}

Scheduler for ordering tests based on duration estimates.

Strategy: Schedule longest tests first (LPT - Longest Processing Time). This helps minimize total execution time by ensuring slow tests start early while faster tests fill in gaps.

Fields

duration_history: HashMap<String, Vec<u64>>

Duration history for each test (node_id -> list of durations in ms)

default_duration_ms: u64

Default duration estimate in ms when no history exists

Implementations

impl TestScheduler

pub fn new() -> Self

Create a new scheduler.

pub fn update_duration(&mut self, node_id: &str, duration_ms: u64)

Update duration history for a test.

pub fn get_estimated_duration(&self, node_id: &str) -> u64

Get estimated duration for a test.

pub fn schedule( &self, node_ids: &[String], failed_first: bool, recent_failures: &[String], ) -> Vec<String>

Schedule tests for optimal execution order.

Args: node_ids: Tests to schedule. failed_first: If true, prioritize recently failed tests. recent_failures: List of node IDs that failed recently.

Returns: Ordered list of node IDs optimized for parallel execution.

pub fn split_balanced( &self, node_ids: &[String], worker_count: usize, ) -> Vec<Vec<String>>

Split tests into N balanced batches using LPT (Longest Processing Time) algorithm.

This distributes tests across workers to minimize total execution time by:

1. Sorting tests by estimated duration (longest first)
2. Greedily assigning each test to the batch with the lowest total duration

Returns a vector of batches, where each batch is a vector of node IDs.

pub fn clear_history(&mut self)

Clear duration history.

pub fn get_history(&self, node_id: &str) -> Option<&Vec<u64>>

Get history for a specific test.

pub fn tracked_count(&self) -> usize

Get total number of tracked tests.

Trait Implementations

impl Clone for TestScheduler

fn clone(&self) -> TestScheduler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TestScheduler

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

Formats the value using the given formatter.

impl Default for TestScheduler

fn default() -> TestScheduler

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for TestScheduler

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TestScheduler

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.