Struct LoopingMutJobService

pub struct LoopingMutJobService(/* private fields */);

Use this as the service type instead of LoopingJobService for mutable jobs that need to be implemented as MutJob instead of Job.

Ideally, LoopingJobService could be used for both Job and MutJob, but it is not possible to write multiple sufficiently generic implementations of From<> for LoopingJobService due to the lack of specialization and negative trait bounds.

Trait Implementations

impl<Mj: MutJob + SelfConfiguredLoop + Send + Sync + 'static> From<Mj> for LoopingMutJobService

fn from(value: Mj) -> Self

Converts to this type from the input type.

impl Service for LoopingMutJobService

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.