Struct LocalJobs 

pub struct LocalJobs { /* private fields */ }

Sets and cancels jobs at a local time, each under a key the app chooses, such as digest:<account id>, so setting it again moves it.

Implementations

impl LocalJobs

pub fn within(db: &Db, reach: Reach) -> Self

For a package resolving its own arguments: what reach owns is what it writes.

pub async fn set<Args, J: Call<JobContext, Args>>( &self, key: &str, job: J, payload: &impl Serialize, at: LocalDateTime, repeat: Repeat, ) -> Result<LocalScheduled>

The first run is the next time at falls at or after now; a single one already past runs at once.

pub async fn cancel(&self, key: &str) -> Result<LocalScheduled>

Nothing changes when no schedule has the key.

Trait Implementations

impl<C: Writes> Resolve<C> for LocalJobs

fn resolve(context: &mut C) -> impl Future<Output = Result<Self>> + Send