Struct JobRegistry 

pub struct JobRegistry { /* private fields */ }

Implementations

impl JobRegistry

pub fn new() -> Self

pub fn register<H>(&mut self, handler: H)

where H: JobHandler + 'static,

pub fn try_register<H>(&mut self, handler: H) -> Result<(), JobRegistryError>

where H: JobHandler + 'static,

pub fn try_register_boxed( &mut self, handler: Arc<dyn JobHandler>, ) -> Result<(), JobRegistryError>

pub fn register_retry_delay_override( &mut self, job_type: JobType<'static>, failure_code: &'static str, retry_delay_ms: i32, )

Registers the policy retry delay for one job type and failure code.

A lower bound attached directly to runledger_core::jobs::JobFailure may extend this delay but can never shorten it. The worker uses its exponential backoff when no matching override exists.

Panics

Panics when retry_delay_ms is not positive.

pub fn get(&self, job_type: JobType<'_>) -> Option<Arc<dyn JobHandler>>

pub fn retry_delay_override( &self, job_type: JobType<'_>, failure_code: &str, ) -> Option<i32>

Returns the configured policy retry delay for an exact job type and failure code.

Handler retry timing is a lower bound that may extend this policy delay but cannot shorten it.

pub fn registered_types(&self) -> Vec<JobType<'_>>

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 Default for JobRegistry

fn default() -> JobRegistry

Returns the “default value” for a type.

impl JobHandlerRegistry for JobRegistry

fn register_boxed(&mut self, handler: Arc<dyn JobHandler>)

fn register<H>(&mut self, handler: H)

where Self: Sized, H: JobHandler + 'static,