Struct CleanupWorker 

pub struct CleanupWorker { /* private fields */ }

Implementations

impl CleanupWorker

pub fn new(storage: Arc<dyn Storage>, interval: Duration) -> Self

pub async fn run_until_cancelled(&self, cancel: CancellationToken) -> Result<()>

Run the cleanup loop until cancel fires.

pub async fn sweep_once(&self) -> Result<usize>

One cleanup sweep. Exposed for tests.

Two pieces of work, in order:

1. Delete jobs whose expires_at has passed (final-state sweep).
2. Delete generic named locks whose expires_at has passed.

Both share a single now so a tick is consistent. Returns the number of expired jobs removed (preserved for backward compatibility with the existing test); named-lock removal is logged but doesn’t change the return.