Struct ScheduledRuntimeTaskGroup 

pub struct ScheduledRuntimeTaskGroup<'a, Name, State, Store, PanicFn, RecordFn, Outcome> { /* private fields */ }

Lease-scoped task group used by product registration closures.

A value of this type exists only while Forge is building the worker group for one lease acquisition. Use Self::worker for singleton workers that should run only on the active owner, and Self::scheduled for tasks that should additionally coordinate each firing through the scheduled task catalog.

Implementations

impl<'a, Name, State, Store, PanicFn, RecordFn, Outcome> ScheduledRuntimeTaskGroup<'a, Name, State, Store, PanicFn, RecordFn, Outcome>

where State: Clone + Send + Sync + 'static,

pub fn worker<WorkerFn, WorkerFut>(&mut self, worker: WorkerFn)

where WorkerFn: FnOnce(CancellationToken, State) -> WorkerFut, WorkerFut: Future<Output = ()> + Send + 'static,

Spawns one lease-scoped singleton worker into this group.

pub fn shutdown_token(&self) -> CancellationToken

Returns a clone of the lease-scoped shutdown token.

pub fn state(&self) -> State

Returns a clone of the product runtime state.

impl<'a, Name, State, Store, PanicFn, RecordFn, Outcome> ScheduledRuntimeTaskGroup<'a, Name, State, Store, PanicFn, RecordFn, Outcome>

where Name: RegisteredRuntimeTaskKind + Send + Sync + 'static, State: Clone + Send + Sync + 'static, Store: ScheduledTaskStore, PanicFn: Clone + Fn(String) -> Outcome + Send + Sync + 'static, RecordFn: Clone + Send + Sync + 'static, Outcome: Send + 'static,

pub fn scheduled<IntervalFn, TaskFn, TaskFut, RecordFut>( &mut self, name: Name, interval_fn: IntervalFn, jitter_cap: Option<Duration>, task_fn: TaskFn, )

where IntervalFn: Fn(&State) -> Duration + Send + Sync + 'static, TaskFn: Fn(State) -> TaskFut + Send + Sync + 'static, TaskFut: Future<Output = Outcome> + Send + 'static, RecordFn: Fn(State, Name, ScheduledTaskClaim, DateTime<Utc>, DateTime<Utc>, Outcome) -> RecordFut, RecordFut: Future<Output = ()> + Send + 'static,

Registers one scheduled runtime task in the lease-scoped worker group.