Struct LoopingJobService

pub struct LoopingJobService { /* private fields */ }

Implementations

impl LoopingJobService

pub fn new<J: Job + 'static>(job: J, config: LoopConfig) -> Self

Trait Implementations

impl From<Arc<dyn LoopableJob>> for LoopingJobService

fn from(job: Arc<dyn LoopableJob>) -> Self

Converts to this type from the input type.

impl<J: LoopableJob + 'static> From<J> for LoopingJobService

fn from(job: J) -> Self

Converts to this type from the input type.

impl Job for LoopingJobService

fn run_once<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn name(&self) -> String

impl Service for LoopingJobService

fn run_forever<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Never> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The service is never expected to stop, it should do its job until externally shutdown.

fn set_heartbeat(&mut self, heartbeat: Arc<dyn Heartbeat>)

The service should frequently call “beat” to indicate that it is still alive.

fn name(&self) -> String

The name used to represent the service in the logs

fn heartbeat_ttl(&self) -> i32

The maximum amount of seconds allowed between heartbeats before the service is deemed “dead”

fn is_healthy(&self) -> bool

The service should be able to self-diagnose any internal issues and report if there is a problem.