Struct ora::TaskDefinition

pub struct TaskDefinition<T = ()> {
    pub target: UnixNanos,
    pub worker_selector: WorkerSelector,
    pub data: Vec<u8, Global>,
    pub data_format: TaskDataFormat,
    pub labels: HashMap<String, Value, RandomState>,
    pub timeout: TimeoutPolicy,
    /* private fields */
}

An untyped complete task definition that can be added to the queue.

Fields

target: UnixNanos

The target time of the task execution.

worker_selector: WorkerSelector

The worker selector of the task.

data: Vec<u8, Global>

Arbitrary task data that is passed to the workers.

data_format: TaskDataFormat

The input data format.

labels: HashMap<String, Value, RandomState>

Arbitrary task labels.

timeout: TimeoutPolicy

An optional timeout policy.

Implementations

impl<T> TaskDefinition<T>

pub fn with_timeout( self, timeout: impl Into<TimeoutPolicy> ) -> TaskDefinition<T>

Set a timeout policy.

pub fn immediate(self) -> TaskDefinition<T>

Schedule the task immediately.

pub fn at(self, target: OffsetDateTime) -> TaskDefinition<T>

Set the target execution time of the new task.

pub fn at_unix(self, target: UnixNanos) -> TaskDefinition<T>

Schedule the task at the given unix nanosecond duration.

pub fn now(self) -> TaskDefinition<T>

Schedule the task with the current time as target.

pub fn after(self, duration: Duration) -> TaskDefinition<T>

Set the target execution time of the new task to be after the given duration.

Panics

Panics if the system time is before UNIX epoch.

pub fn with_worker_selector( self, selector: impl Into<WorkerSelector> ) -> TaskDefinition<T>

Set the worker selector for the given task.

pub fn with_label(self, name: &str, value: impl Serialize) -> TaskDefinition<T>

Set a label value.

Panics

Panics if the value is not JSON-serializable.

pub fn cast<U>(self) -> TaskDefinition<U>

Cast the task to a different task type, or to erase the task type replacing it with ().

This is not required in most circumstances.

Trait Implementations

impl<T> Clone for TaskDefinition<T>

fn clone(&self) -> TaskDefinition<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Debug for TaskDefinition<T>where T: Debug,

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

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for TaskDefinition<T>

fn deserialize<__D>( __deserializer: __D ) -> Result<TaskDefinition<T>, <__D as Deserializer<'de>>::Error>where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T> Serialize for TaskDefinition<T>

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

Serialize this value into the given Serde serializer.