Struct TaskSchedulerBuilder 

pub struct TaskSchedulerBuilder<'a, S: Clone> { /* private fields */ }

Implementations

impl<'a, S: Clone + Send + Sync + 'static> TaskSchedulerBuilder<'a, S>

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

Set a string key for task identification

pub fn schedule_at(self, timestamp: Timestamp) -> Self

Schedule for a specific absolute timestamp

pub fn schedule_after(self, seconds: i64) -> Self

Schedule after a relative delay (in seconds)

pub fn depend_on(self, deps: Vec<TaskId>) -> Self

Add task dependencies - task waits for all of these to complete

pub fn depends_on(self, dep: TaskId) -> Self

Add a single task dependency

pub fn with_retry(self, policy: RetryPolicy) -> Self

Enable automatic retry with exponential backoff

pub fn cron(self, expr: impl Into<String>) -> Self

Schedule task with cron expression Example: .cron("0 9 * * *") for 9 AM daily

pub fn daily_at(self, hour: u8, minute: u8) -> Self

Schedule task daily at specified time Example: .daily_at(2, 30) for 2:30 AM daily

pub fn weekly_at(self, weekday: u8, hour: u8, minute: u8) -> Self

Schedule task weekly at specified day and time Example: .weekly_at(1, 14, 30) for Mondays at 2:30 PM weekday: 0=Sunday, 1=Monday, …, 6=Saturday

pub fn run_on_startup(self) -> Self

Opt-in: if this is a cron task and a scheduled run was missed while the server was down (or this is the first time the task is being registered), run it once immediately on startup before resuming the normal cron schedule.

pub async fn now(self) -> ClResult<TaskId>

Execute the scheduled task immediately

pub async fn at(self, ts: Timestamp) -> ClResult<TaskId>

Execute the scheduled task at a specific timestamp

pub async fn after(self, seconds: i64) -> ClResult<TaskId>

Execute the scheduled task after a delay (in seconds)

pub async fn after_task(self, dep: TaskId) -> ClResult<TaskId>

Execute the scheduled task after another task completes

pub async fn with_automatic_retry(self) -> ClResult<TaskId>

Execute the scheduled task with automatic retry using default policy

pub async fn schedule(self) -> ClResult<TaskId>

Execute the task with all configured options - main terminal method