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) -> Result<DecisionLog>

A snapshot of the decisions observed so far.

Errors

Returns [Error::Scheduler] if the recording log mutex is poisoned.

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.

fn population_report_mode(&self) -> PopulationReportMode

Declares whether this scheduler accepts one shared report batch from several population members. This is distinct from fanned replicate reports. The default is fail-closed.

fn on_population_report( &self, study: &StudyView, reports: &[PopulationReport], ) -> Result<Vec<PopulationDecision>, Error>

Decides all members at one population boundary from the same snapshot.