Struct SorterHandle 

pub struct SorterHandle { /* private fields */ }

A handle to the process Sorter. Clone freely; all clones address the one governor actor.

Implementations

impl SorterHandle

pub fn spawn( config: SorterConfig, fd_budget: u32, pressure: Arc<dyn MemoryPressure>, scratch_root: PathBuf, ) -> Self

Spawn the governor and return a handle to it. fd_budget is the number of usable file descriptors the Sorter may ration (the process soft limit minus a safety margin); sorts spill under unique directories beneath scratch_root.

pub async fn submit(&self, spec: SortSpec) -> Result<SortLease, SorterError>

Admit a sort: the governor plans it, reserves its resources, and returns a lease. The returned lease must be held until the sort’s value stream is fully consumed.

Errors

Returns SorterError::Gone if the governor is no longer running.

pub async fn stats(&self) -> Result<SorterStats, SorterError>

Read the governor’s current counters.

Errors

Returns SorterError::Gone if the governor is no longer running.

Trait Implementations

impl Clone for SorterHandle

fn clone(&self) -> SorterHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.