Struct Tasks 

pub struct Tasks { /* private fields */ }

Registers jobs and runs a worker (and optional scheduler) as [BackgroundService]s.

Implementations

impl Tasks

pub fn new(store: Arc<dyn TaskStore>) -> Self

pub fn memory() -> Self

In-memory queue (tests / single process).

pub fn queue(self, q: impl Into<String>) -> Self

Single queue (shorthand for Self::queues).

pub fn queues<I, S>(self, qs: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Claim order = priority across queues (first is highest).

pub fn lease(self, d: Duration) -> Self

pub fn poll_interval(self, d: Duration) -> Self

pub fn max_attempts(self, n: u32) -> Self

pub fn retry_base(self, d: Duration) -> Self

pub fn scheduler_tick(self, d: Duration) -> Self

pub fn job(self, job: JobDef) -> Self

pub fn exposed(self) -> Self

pub fn guard<F>(self, f: F) -> Self

where F: Fn(&Request) -> bool + Send + Sync + 'static,

Trait Implementations

impl Plugin for Tasks

fn id(&self) -> &'static str

Stable plugin identifier used for dependency checks and crate::App::has_plugin.

fn meta(&self) -> PluginMeta

Display name, description, and declared PluginMeta::sdk version.

fn install(self, app: &mut App)

Register middleware, state, routes, and hooks on app.

fn requires(&self) -> &'static [&'static str]

Required plugin ids that must be installed beforehand.