Struct SessionReaper 

pub struct SessionReaper { /* private fields */ }

Background session reaper. Runs in its own thread, periodically scanning the coordinator for expired sessions.

Implementations

impl SessionReaper

pub fn new(coordinator: Arc<Mutex<Coordinator>>, config: ReaperConfig) -> Self

Create a new reaper for the given shared coordinator.

pub fn start(&self)

Start the reaper in a background thread.

pub fn stop(&self)

Stop the reaper.

pub fn reap_once(&self) -> usize

Run one reaping pass synchronously. Returns the number of sessions that were expired.