Struct MessageHeaders 

pub struct MessageHeaders {
    pub task: String,
    pub id: Uuid,
    pub lang: String,
    pub root_id: Option<Uuid>,
    pub parent_id: Option<Uuid>,
    pub group: Option<Uuid>,
    pub retries: Option<u32>,
    pub eta: Option<DateTime<Utc>>,
    pub expires: Option<DateTime<Utc>>,
    pub extra: HashMap<String, Value>,
}

Message headers (Celery protocol)

Fields

task: String

Task name (e.g., “tasks.add”)

id: Uuid

Task ID (UUID)

lang: String

Programming language (“rust”, “py”)

root_id: Option<Uuid>

Root task ID (for workflow tracking)

parent_id: Option<Uuid>

Parent task ID (for nested tasks)

group: Option<Uuid>

Group ID (for grouped tasks)

retries: Option<u32>

Maximum retries

eta: Option<DateTime<Utc>>

ETA (Estimated Time of Arrival) for delayed tasks

expires: Option<DateTime<Utc>>

Task expiration timestamp

extra: HashMap<String, Value>

Additional custom headers

Implementations

impl MessageHeaders

pub fn new(task: String, id: Uuid) -> Self

pub fn with_lang(self, lang: String) -> Self

Set the language field (builder pattern)

pub fn with_root_id(self, root_id: Uuid) -> Self

Set the root ID field (builder pattern)

pub fn with_parent_id(self, parent_id: Uuid) -> Self

Set the parent ID field (builder pattern)

pub fn with_group(self, group: Uuid) -> Self

Set the group field (builder pattern)

pub fn with_retries(self, retries: u32) -> Self

Set the retries field (builder pattern)

pub fn with_eta(self, eta: DateTime<Utc>) -> Self

Set the ETA field (builder pattern)

pub fn with_expires(self, expires: DateTime<Utc>) -> Self

Set the expires field (builder pattern)

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

Validate message headers

Trait Implementations

impl Clone for MessageHeaders

fn clone(&self) -> MessageHeaders

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageHeaders

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MessageHeaders

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for MessageHeaders

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for MessageHeaders

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for MessageHeaders

impl StructuralPartialEq for MessageHeaders