Struct Task 

pub struct Task {
    pub id: u128,
    pub task_type: TaskType,
    pub contents: Value,
    pub model: Option<String>,
    pub max_tokens: Option<u64>,
    pub payload: Option<Value>,
}

Serializable envelope for work submitted to a queue or executor.

Use TaskBuilder for chat tasks. Derived Default has ID zero and null contents, so it is not an executable chat request.

Fields

id: u128

Correlation ID; memory queues require uniqueness for outstanding tasks.

task_type: TaskType

Operation encoded in Self::contents.

contents: Value

JSON input matching the task type; chat tasks contain a TaskChat.

model: Option<String>

Explicit model, or None to use the producer/executor default.

max_tokens: Option<u64>

Requested output limit; the API executor casts this to u32 unchecked.

payload: Option<Value>

Opaque caller metadata preserved in the response task.

Implementations

impl Task

pub async fn send_and_wait<Q: QueueProducer>( self, queue: &Q, timeout_secs: Option<u64>, ) -> Result<Response>

Submits this task and retrieves its response, which may be unsuccessful.

With std, Some(seconds) limits only the response wait after submission and requires a Tokio runtime with time enabled. Expiry does not cancel worker execution. None adds no timeout; backend polling semantics still apply. Without std, a supplied timeout errors before sending.

Submission/retrieval failures, timeout expiry, and None responses return errors. Check the response’s success field separately from the Result.

impl Task

pub fn with_id(self, id: u128) -> Self

Replaces the correlation ID; avoid duplicates among outstanding tasks.

pub fn with_max_tokens(self, max_tokens: u64) -> Self

Sets the output limit; the API executor casts it to u32 unchecked.

pub fn with_payload<P: Serialize>(self, payload: P) -> Self

Attaches opaque caller metadata to be returned with the task.

Panics

Panics if the payload cannot be serialized as JSON.

pub fn with_model<M: ToString>(self, model: M) -> Self

Overrides the model used for NATS routing and API execution.

pub fn try_to_chat(&self) -> Result<TaskChat>

Decodes contents as TaskChat, returning an error for incompatible JSON.

Does not inspect Self::task_type or validate schema/model settings.

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Task

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

Formats the value using the given formatter.

impl Default for Task

fn default() -> Task

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Task

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Task

impl PartialEq for Task

fn eq(&self, other: &Task) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for Task

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Task