Struct JobRegistry 

pub struct JobRegistry { /* private fields */ }

Thread-safe job registry.

Stores running jobs and keeps completed jobs for a retention window.

Implementations

impl JobRegistry

pub fn new(completed_retention: Duration) -> Self

pub fn completed_retention(&self) -> Duration

pub async fn insert(&self, job_id: String, job: SharedJobState)

pub async fn get(&self, job_id: &str) -> Option<SharedJobState>

pub async fn remove(&self, job_id: &str) -> Option<SharedJobState>

pub async fn prune_expired(&self) -> usize

Remove completed jobs that exceeded the retention window.

Returns the number of pruned jobs.

Trait Implementations

impl Clone for JobRegistry

fn clone(&self) -> JobRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JobRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.