Struct TaskBuilder 

pub struct TaskBuilder<Args> { /* private fields */ }

Builder for creating Task instances with optional configuration

Implementations

impl<Args> TaskBuilder<Args>

pub fn new(args: Args) -> Self

Create a new TaskBuilder with the required args

pub fn with_metadata(self, metadata: MetadataStore) -> Self

Set the task’s metadata

pub fn with_data(self, data: Extensions) -> Self

Set the task’s runtime data

pub fn data<D: Clone + Send + Sync + 'static>(self, value: D) -> Self

Insert a value into the task’s data context

pub fn metadata<M>(self, value: &M) -> Self

where M: Metadata, M::Error: Debug,

Insert a value into the task’s metadata

pub fn task_id(self, task_id: TaskId) -> Self

Set the task ID

pub fn attempt(self, attempt: usize) -> Self

Set the attempt information

pub fn status(self, status: Status) -> Self

Set the task status

pub fn max_attempts(self, max_attempts: usize) -> Self

Set the maximum number of attempts allowed for the task

pub fn priority(self, priority: usize) -> Self

Set the priority of the task

pub fn queue(self, queue: Queue) -> Self

Set the queue this task belongs to

pub fn run_at_timestamp(self, timestamp: u64) -> Self

Schedule the task to run at a specific Unix timestamp

pub fn run_at_time(self, time: SystemTime) -> Self

Schedule the task to run at a specific SystemTime

pub fn run_after(self, delay: Duration) -> Self

Schedule the task to run after a delay from now

pub fn run_in_seconds(self, seconds: u64) -> Self

Schedule the task to run in the specified number of seconds

pub fn run_in_minutes(self, minutes: u64) -> Self

Schedule the task to run in the specified number of minutes

pub fn run_in_hours(self, hours: u64) -> Self

Schedule the task to run in the specified number of hours

pub fn idempotency_key<S: AsRef<str>>(self, idempotency_key: S) -> Self

Set the idempotency key

pub fn done_at(self, done_at: Option<u64>) -> Self

Set the time the task was completed

pub fn lock_at(self, lock_at: Option<u64>) -> Self

Set the time the task was locked

pub fn lock_by(self, lock_by: Option<String>) -> Self

Set the worker/process identifier holding the lock on this task

pub fn build(self) -> Task<Args>

Build the Task with default context

impl<Args> TaskBuilder<Args>

pub fn try_map_args<F, NewArgs, Err>( self, f: F, ) -> Result<TaskBuilder<NewArgs>, Err>

where F: FnOnce(Args) -> Result<NewArgs, Err>,

Maps the args field using the provided function, returning a result.

pub fn map_args<F, NewArgs>(self, f: F) -> TaskBuilder<NewArgs>

where F: FnOnce(Args) -> NewArgs,

Maps the args field using the provided function, returning the new args.

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

where F: FnOnce(ExecutionContext) -> ExecutionContext,

Maps only the execution_context field.

Trait Implementations

impl<Args: Debug> Debug for TaskBuilder<Args>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de, Args> Deserialize<'de> for TaskBuilder<Args>

where Args: Deserialize<'de>,

Available on crate feature serde only.

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<Args> Serialize for TaskBuilder<Args>

where Args: Serialize,

Available on crate feature serde only.

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.