Struct Headers 

pub struct Headers {
    pub correlation_id: Option<UUID4>,
    pub causation_id: Option<UUID4>,
}

First-class metadata propagated end-to-end across captured messages.

Fields are ordered from most abstract (workflow grouping) to most concrete (one-hop lineage), matching the CQRS / event-sourcing convention (EventStore, Axon, Marten all list correlation, then causation, then message id). All fields default to None so capture works before propagation discipline lands across the command, event, and reconciliation report types. Once a field is populated, the bus capture adapter writes it through; replay never invents values.

Agent-level intent is not a separate field at this layer: when an agent decision is lowered into a bus message, the agent’s intent_id is written to the message’s correlation_id, so forensics queries that need “find by agent intent” scan the captured stream by correlation_id.

Fields

correlation_id: Option<UUID4>

The correlation chain id that ties commands, events, and reports to one logical action.

causation_id: Option<UUID4>

The id of the message that directly caused this one, if any.

Implementations

impl Headers

pub const fn empty() -> Self

Creates a new Headers with all fields unset.

pub const fn is_empty(&self) -> bool

Returns true if every header field is unset.

Trait Implementations

impl Clone for Headers

fn clone(&self) -> Headers

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Headers

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

Formats the value using the given formatter.

impl Default for Headers

fn default() -> Headers

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Headers

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Headers

impl Hash for Headers

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for Headers

fn eq(&self, other: &Headers) -> 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 Headers

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 Headers