Struct JobRunnerBuilder

pub struct JobRunnerBuilder<F, Fut, T, E, CONTEXT>
where
    F: Fn(RunningJob, CONTEXT) -> Fut + Send + Sync + Clone + 'static,
    CONTEXT: Send + Sync + Debug + Clone + 'static,
    Fut: Future<Output = Result<T, E>> + Send,
    T: Send + Debug + Serialize + 'static,
    E: Send + Debug + Display + 'static,
{ /* private fields */ }

A builder object for a JobRunner.

Implementations

impl<F, Fut, T, E, CONTEXT> JobRunnerBuilder<F, Fut, T, E, CONTEXT>

where F: Fn(RunningJob, CONTEXT) -> Fut + Send + Sync + Clone + 'static, CONTEXT: Send + Sync + Debug + Clone + 'static, Fut: Future<Output = Result<T, E>> + Send, T: Send + Debug + Serialize + 'static, E: Send + Debug + Display + 'static,

pub fn new(name: impl Into<SmartString<LazyCompact>>, runner_fn: F) -> Self

Create a new JobRunnerBuilder.

pub fn autoheartbeat(self, autoheartbeat: bool) -> Self

Set whether the job should automatically send heartbeats while it runs.

pub fn format_failures_with_debug( self, format_failures_with_debug: bool, ) -> Self

If true, format failures with the Debug implementation when storing the information in the database. If false, use the Display implementation. The default is false.

pub fn build(self) -> JobRunner<CONTEXT>

Consume the builder, returning a JobRunner.