Struct app_task::TaskRunner

pub struct TaskRunner<T, SF = DefaultStrategyFactory<ConstantTimeBackoff>> { /* private fields */ }

Implementations

impl<T> TaskRunner<T>

pub fn new(app: Arc<T>) -> Self

impl<T, SF> TaskRunner<T, SF>

where T: Send + Sync + 'static, SF: StrategyFactory,

pub fn with_default_strategy<NS>( self, ) -> TaskRunner<T, DefaultStrategyFactory<NS>>

where NS: StrategyFactory,

pub fn with_strategy<NSF>(self, backoff_strategy: NSF) -> TaskRunner<T, NSF>

impl<T, SF> TaskRunner<T, SF>

where T: Send + Sync + 'static, SF: StrategyFactory,

pub fn spawn_task<S, C, F, E>( &self, label: S, task: C, ) -> JoinHandle<Result<(), Box<dyn Any + Send>>>

where S: ToString, C: Fn(Arc<T>) -> F + Send + Sync + 'static, F: Future<Output = Result<(), E>> + Send + 'static + UnwindSafe, E: Display + Send + Sync,

Spawns a task that will run until it returns Ok(()) or panics. If the task returns an error, it will be logged and the task will be retried with a backoff.

If the task panics, the panic output will be returned as an error.