Struct RecordingScheduler 

pub struct RecordingScheduler { /* private fields */ }

A Scheduler decorator that records the pauses and resumes of the scheduler it wraps, delegating every decision (and its persisted state) unchanged.

The transparency is the point: it must not alter a single decision, only observe it, so the oracle asserts what the real scheduler did.

Implementations

impl RecordingScheduler

pub fn new(inner: Arc<dyn Scheduler>) -> Self

Wraps inner, recording its pause and resume decisions.

pub fn log(&self) -> DecisionLog

A snapshot of the decisions observed so far.

Trait Implementations

impl Debug for RecordingScheduler

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

Formats the value using the given formatter.

impl Scheduler for RecordingScheduler

fn on_report( &self, study: &StudyView, trial: &TrialMeta, step: u64, values: &[f64], ) -> Result<Decision>

Called on every intermediate report.

fn on_trial_end( &self, study: &StudyView, trial: &FrozenTrial, ) -> Result<Vec<Command>>

Called once a trial reaches a terminal state.

fn resume_candidates(&self, study: &StudyView) -> Result<Vec<Command>>

Paused trials worth waking on a freed work slot, in priority order.

fn state(&self) -> Result<Option<StateBlob>>

The scheduler’s persistable state, if it has any.

fn restore_state(&self, blob: &StateBlob) -> Result<()>

Restores a scheduler from a previously persisted blob.

fn scripted_capability(&self) -> ScriptedSchedulerCapability

Declares whether scripted ask/tell can recreate this scheduler.

fn fan_report_mode(&self) -> FanReportMode

Declares whether this scheduler accepts aligned aggregate fan reports.