Struct RefinementRuntime 

pub struct RefinementRuntime<C = ()> { /* private fields */ }

Stateful method-independent refinement boundary guard.

Implementations

impl<C> RefinementRuntime<C>

pub fn new( limits: RefinementLimits, cancellation: Option<CancellationToken>, ) -> Result<Self, RuntimeError>

Construct a runtime with a process-local monotonic clock.

Errors

Returns RuntimeError::InvalidClock if the clock origin is invalid.

pub fn with_clock( limits: RefinementLimits, cancellation: Option<CancellationToken>, clock: Arc<dyn RuntimeClock>, ) -> Result<Self, RuntimeError>

Construct a runtime with an injectable thread-safe clock.

Errors

Returns RuntimeError::InvalidClock if the first timestamp is non-finite.

pub fn set_event_sink(&mut self, sink: impl RefinementEventSink + 'static)

Attach a synchronous event sink. Sink failures are isolated and recorded.

pub fn set_checkpoint_sink(&mut self, sink: impl CheckpointSink<C> + 'static)

Attach an application-owned typed checkpoint sink.

pub fn resume_accepted( &mut self, completed_iterations: usize, ) -> Result<(), RuntimeError>

Restore accepted/attempted counters from a validated checkpoint.

Evaluation and rejection budgets restart for the continuation call.

Errors

Returns RuntimeError::InvalidResume if work already began or the completed count exceeds the iteration budget.

pub fn elapsed_seconds(&self) -> Result<f64, RuntimeError>

Return finite non-negative elapsed seconds.

Errors

Returns RuntimeError::InvalidClock for non-finite or backward time.

pub fn emit( &mut self, kind: RefinementEventKind, stage: impl Into<String>, message: impl Into<String>, diagnostics: Vec<(String, DiagnosticValue)>, ) -> Result<RefinementEvent, RuntimeError>

Emit one validated event and isolate a failing event sink.

Errors

Returns RuntimeError for clock or event validation failures. A sink failure does not invalidate numerical state and is stored separately.

pub fn check_boundary(&self) -> Result<(), RuntimeError>

Stop at a safe boundary for cancellation, time, or evaluation budget.

Errors

Returns RuntimeError::Stopped for a normal bounded stop, or a clock/ cancellation-state error.

pub fn begin_iteration( &mut self, attempted_iteration: usize, ) -> Result<(), RuntimeError>

Begin one strictly increasing attempted iteration.

Errors

Returns RuntimeError for order violations or a normal bounded stop.

pub fn begin_evaluation(&mut self) -> Result<(), RuntimeError>

Reserve one model evaluation after checking every safe-boundary budget.

Errors

Returns RuntimeError for a normal bounded stop or invalid clock/token.

pub fn accept_step( &mut self, checkpoint: Option<&C>, ) -> Result<(), RuntimeError>

Accept at most one step in the current attempted iteration.

State becomes accepted before the optional checkpoint sink is called, so a sink failure never rolls numerical state backward.

Errors

Returns RuntimeError for acceptance-order, counter, checkpoint, event, or clock failures.

pub fn reject_step(&mut self) -> Result<(), RuntimeError>

Record a rejection and enforce its consecutive budget.

Errors

Returns RuntimeError::Stopped when the rejection limit is reached.

pub const fn attempted_iteration(&self) -> usize

Return the attempted iteration counter.

pub const fn accepted_iterations(&self) -> usize

Return the accepted iteration counter.

pub const fn evaluations(&self) -> usize

Return the model-evaluation counter.

pub const fn consecutive_rejections(&self) -> usize

Return consecutive rejected steps since the last acceptance.

pub fn event_sink_error(&self) -> Option<&str>

Borrow the isolated event-sink error, if any.

pub const fn has_event_sink(&self) -> bool

Return whether an event sink remains attached.