Struct ScanJobTracker 

pub struct ScanJobTracker { /* private fields */ }

Monotonic progress tracker used inside one worker process.

Implementations

impl ScanJobTracker

pub fn new(run_id: impl Into<String>, policy: ExecutionPolicy) -> Self

Starts a tracker for one run at configuration validation.

pub fn with_clock( run_id: impl Into<String>, policy: ExecutionPolicy, clock: Arc<dyn MonotonicClock>, ) -> Self

Starts a tracker with an injected monotonic clock for deterministic execution tests.

pub fn enter_phase( &mut self, phase: JobPhase, ) -> Result<(), ExecutionLimitExceeded>

Changes phase after checking the active deadlines.

Errors

Returns ExecutionLimitExceeded when wall time or no-progress time is exhausted.

pub fn progress(&mut self, amount: u64) -> Result<(), ExecutionLimitExceeded>

Charges verified completed work using checked arithmetic.

Errors

Returns ExecutionLimitExceeded on arithmetic overflow or an exhausted deadline.

pub fn check_time(&self) -> Result<(), ExecutionLimitExceeded>

Checks monotonic wall time and time since the last verified progress.

Errors

Returns ExecutionLimitExceeded when either effective duration is exhausted.

Trait Implementations

impl Debug for ScanJobTracker

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

Formats the value using the given formatter.