Struct MessageHeadersRef 

pub struct MessageHeadersRef<'a> {
    pub task: Cow<'a, str>,
    pub id: Uuid,
    pub lang: Cow<'a, str>,
    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<Cow<'a, str>, Value>,
}

Zero-copy message headers

Uses Cow<'a, str> to avoid unnecessary string allocations when deserializing.

Fields

task: Cow<'a, str>

Task name (zero-copy reference)

id: Uuid

Task ID

lang: Cow<'a, str>

Programming language

root_id: Option<Uuid>

Root task ID

parent_id: Option<Uuid>

Parent task ID

group: Option<Uuid>

Group ID

retries: Option<u32>

Maximum retries

eta: Option<DateTime<Utc>>

ETA for delayed tasks

expires: Option<DateTime<Utc>>

Task expiration timestamp

extra: HashMap<Cow<'a, str>, Value>

Additional custom headers

Trait Implementations

impl<'a> Clone for MessageHeadersRef<'a>

fn clone(&self) -> MessageHeadersRef<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for MessageHeadersRef<'a>

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

Formats the value using the given formatter.

impl<'de: 'a, 'a> Deserialize<'de> for MessageHeadersRef<'a>

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'a> Serialize for MessageHeadersRef<'a>

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

where __S: Serializer,

Serialize this value into the given Serde serializer.