pub struct ScheduledPeriodicTask<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn> {
pub name: Name,
pub namespace: &'static str,
pub task_name: &'static str,
pub display_name: &'static str,
pub owner_id: String,
pub claim_ttl: Duration,
pub interval_fn: IntervalFn,
pub jitter_cap: Option<Duration>,
pub shutdown_token: CancellationToken,
pub state: State,
pub store: Store,
pub hooks: RecordedTaskHooks<TaskFn, PanicFn, RecordFn>,
}Expand description
Configuration for one scheduled periodic runtime task worker.
Fields§
§name: NameProduct task identifier.
namespace: &'static strProduct namespace.
task_name: &'static strStable task wire name.
display_name: &'static strOperator-facing display name.
owner_id: StringProcess-unique runtime owner id.
claim_ttl: DurationClaim TTL used to recover from crashed workers.
interval_fn: IntervalFnReads the latest product-configured interval.
jitter_cap: Option<Duration>Optional upper bound for positive jitter.
shutdown_token: CancellationTokenShared shutdown token.
state: StateProduct runtime state passed to callbacks.
store: StoreScheduled task store.
hooks: RecordedTaskHooks<TaskFn, PanicFn, RecordFn>Product callbacks for execution, panic conversion, and recording.
Auto Trait Implementations§
impl<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn> Freeze for ScheduledPeriodicTask<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn>
impl<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn> RefUnwindSafe for ScheduledPeriodicTask<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn>where
Name: RefUnwindSafe,
IntervalFn: RefUnwindSafe,
State: RefUnwindSafe,
Store: RefUnwindSafe,
TaskFn: RefUnwindSafe,
PanicFn: RefUnwindSafe,
RecordFn: RefUnwindSafe,
impl<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn> Send for ScheduledPeriodicTask<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn>
impl<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn> Sync for ScheduledPeriodicTask<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn>
impl<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn> Unpin for ScheduledPeriodicTask<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn>
impl<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn> UnsafeUnpin for ScheduledPeriodicTask<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn>where
Name: UnsafeUnpin,
IntervalFn: UnsafeUnpin,
State: UnsafeUnpin,
Store: UnsafeUnpin,
TaskFn: UnsafeUnpin,
PanicFn: UnsafeUnpin,
RecordFn: UnsafeUnpin,
impl<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn> UnwindSafe for ScheduledPeriodicTask<Name, State, Store, IntervalFn, TaskFn, PanicFn, RecordFn>where
Name: UnwindSafe,
IntervalFn: UnwindSafe,
State: UnwindSafe,
Store: UnwindSafe,
TaskFn: UnwindSafe,
PanicFn: UnwindSafe,
RecordFn: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more