Struct RepackScheduler 

pub struct RepackScheduler { /* private fields */ }

Bounded background scheduler shared by native and hosted repack payloads.

Implementations

impl RepackScheduler

pub fn new( policy: RepackPolicy, limits: RepackResourceLimits, ) -> RepackScheduler

Construct a scheduler with configurable triggers and resource limits.

pub fn with_load_monitor(self, load: Arc<dyn LoadMonitor>) -> RepackScheduler

Install a foreground-load signal used by worker checkpoints.

pub fn with_backoff( self, success: Duration, initial_failure: Duration, maximum_failure: Duration, ) -> RepackScheduler

Override success and exponential failure backoff windows.

pub fn schedule_if_needed( &self, operation: Arc<dyn RepackOperation>, ) -> Result<RepackSchedule, RepackError>

Inspect thresholds and start a background operation when needed.

pub fn repack_now( &self, operation: Arc<dyn RepackOperation>, ) -> Result<RepackSchedule, RepackError>

Start an operator-requested repack, bypassing heuristics and backoff.

pub fn repack_now_with_token( &self, operation: Arc<dyn RepackOperation>, cancellation: CancellationToken, ) -> Result<RepackSchedule, RepackError>

Start a manual repack controlled by an existing cancellation token.

Trait Implementations

impl Clone for RepackScheduler

fn clone(&self) -> RepackScheduler

Returns a duplicate of the value.

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

Performs copy-assignment from source.