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 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