Struct StaleSweeper 

pub struct StaleSweeper {
    handle: JoinHandle<()>,
    stop: Arc<Notify>,
}

A running sweep, stopped by StaleSweeper::stop or by dropping it.

Fields

handle: JoinHandle<()>

stop: Arc<Notify>

Implementations

impl StaleSweeper

pub fn spawn(registry: Arc<dyn StaleSweep>, schedule: SweepSchedule) -> Self

Starts sweeping registry on schedule.

The first tick fires immediately, so a process that has just come back from the crash that stranded an account starts reaping at once. That pass runs alongside serving.

The sweep itself runs on a blocking thread: it takes the same write lock every write path takes, and a task doing that on a runtime worker holds the worker for the duration. That is also what makes a panicking sweep survivable — the panic arrives here as a join error, is logged, and the next tick tries again rather than the timer dying with it.

pub async fn stop(self)

Stops the sweep and waits for the task to finish.

Trait Implementations

impl Drop for StaleSweeper

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.