Skip to main content

spawn_task_heartbeat_with_interval

Function spawn_task_heartbeat_with_interval 

Source
pub fn spawn_task_heartbeat_with_interval<Store, LeaseExpiresFn>(
    store: Store,
    lease_guard: TaskLeaseGuard,
    stop_token: CancellationToken,
    interval: Duration,
    lease_expires_at: LeaseExpiresFn,
) -> JoinHandle<()>
where Store: TaskHeartbeatStore + 'static, LeaseExpiresFn: Fn(DateTime<Utc>) -> DateTime<Utc> + Send + Sync + 'static,
Expand description

Spawns a heartbeat worker with the provided interval.