Struct SerializedTask 

pub struct SerializedTask {
    pub metadata: TaskMetadata,
    pub payload: Vec<u8>,
}

Serialized task ready for queue

Zero-Copy Serialization Considerations

The current implementation uses Vec<u8> for the payload, which requires copying data during serialization and deserialization. For high-performance scenarios, consider these alternatives:

1. Bytes from bytes crate: Provides cheap cloning via reference counting

   use bytes::Bytes;
   pub payload: Bytes,

2. Arc<[u8]>: Reference-counted slice for shared ownership

   use std::sync::Arc;
   pub payload: Arc<[u8]>,

3. Borrowed payloads with lifetimes: For truly zero-copy deserialization

   #[derive(Deserialize)]
   pub struct SerializedTask<'a> {
       #[serde(borrow)]
       pub payload: &'a [u8],
   }

Trade-offs:

• Vec<u8>: Simple, owned data, but requires copying
• Bytes: Cheap cloning, but requires external dependency
• Arc<[u8]>: Cheap cloning, but atomic operations have overhead
• Borrowed: True zero-copy, but lifetime complexity and limited use cases

For most use cases, the current Vec<u8> approach provides a good balance of simplicity and performance. Consider alternatives only when profiling shows serialization as a bottleneck.

Fields

metadata: TaskMetadata

Task metadata

payload: Vec<u8>

Serialized task payload

Implementations

impl SerializedTask

pub fn new(name: String, payload: Vec<u8>) -> Self

pub fn with_priority(self, priority: i32) -> Self

pub fn with_max_retries(self, max_retries: u32) -> Self

pub fn with_timeout(self, timeout_secs: u64) -> Self

pub fn with_group_id(self, group_id: Uuid) -> Self

Set the group ID for workflow grouping

pub fn with_chord_id(self, chord_id: Uuid) -> Self

Set the chord ID for barrier synchronization

pub fn age(&self) -> Duration

Get the age of the task (time since creation)

pub fn is_expired(&self) -> bool

Check if the task has expired based on its timeout

pub fn is_terminal(&self) -> bool

Check if the task is in a terminal state (Success or Failure)

pub fn is_active(&self) -> bool

Check if the task is in a running or active state

pub fn validate(&self) -> Result<(), String>

Validate the serialized task

Validates both metadata and payload constraints:

• Delegates metadata validation to TaskMetadata::validate()
• Checks payload size (must be < 1MB by default)

Errors

Returns an error if validation fails.

pub fn validate_with_limit( &self, max_payload_bytes: usize, ) -> Result<(), String>

Validate with custom payload size limit

Errors

Returns an error if validation fails.

pub fn has_timeout(&self) -> bool

Check if task has a timeout configured

pub fn has_group_id(&self) -> bool

Check if task is part of a group

pub fn has_chord_id(&self) -> bool

Check if task is part of a chord

pub fn has_priority(&self) -> bool

Check if task has custom priority (non-zero)

pub const fn payload_size(&self) -> usize

Get payload size in bytes

pub fn has_empty_payload(&self) -> bool

Check if payload is empty

pub fn with_dependency(self, dependency: TaskId) -> Self

Add a task dependency

pub fn with_dependencies( self, dependencies: impl IntoIterator<Item = TaskId>, ) -> Self

Add multiple task dependencies

pub fn has_dependencies(&self) -> bool

Check if task has any dependencies

pub fn dependency_count(&self) -> usize

Get the number of dependencies

pub fn depends_on(&self, task_id: &TaskId) -> bool

Check if a specific task is a dependency

pub fn is_high_priority(&self) -> bool

Check if task has high priority (priority > 0)

pub fn is_low_priority(&self) -> bool

Check if task has low priority (priority < 0)

pub fn is_pending(&self) -> bool

Check if task is in Pending state

pub fn is_running(&self) -> bool

Check if task is in Running state

pub fn is_succeeded(&self) -> bool

Check if task is in Succeeded state

pub fn is_failed(&self) -> bool

Check if task is in Failed state

pub fn is_retrying(&self) -> bool

Check if task is in Retrying state

pub fn is_reserved(&self) -> bool

Check if task is in Reserved state

pub fn time_remaining(&self) -> Option<Duration>

Get remaining time before timeout

pub fn time_elapsed(&self) -> Duration

Get the time elapsed since task creation

pub fn can_retry(&self) -> bool

Check if task can be retried

pub const fn retry_count(&self) -> u32

Get current retry count

pub const fn retries_remaining(&self) -> u32

Get remaining retry attempts

pub fn is_part_of_workflow(&self) -> bool

Check if task is part of any workflow

pub fn get_group_id(&self) -> Option<&Uuid>

Get group ID if task is part of a group

pub fn get_chord_id(&self) -> Option<&Uuid>

Get chord ID if task is part of a chord

Trait Implementations

impl Clone for SerializedTask

fn clone(&self) -> SerializedTask

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SerializedTask

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SerializedTask

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for SerializedTask

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

Formats the value using the given formatter.

impl Serialize for SerializedTask

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

where __S: Serializer,

Serialize this value into the given Serde serializer.