Struct MessageMetadata 

pub struct MessageMetadata {
    pub timestamp: Option<Duration>,
    pub source: Option<String>,
    pub partition: Option<u32>,
    pub offset: Option<u64>,
    pub key: Option<String>,
    pub headers: Vec<(String, String)>,
}

Metadata associated with a message.

Fields

timestamp: Option<Duration>

When the message was created (as Duration since UNIX_EPOCH).

source: Option<String>

The source of the message (e.g., topic, file, etc.).

partition: Option<u32>

Partition or shard information.

offset: Option<u64>

Offset within the partition/source.

key: Option<String>

User-defined key for routing/grouping.

headers: Vec<(String, String)>

Additional headers/attributes.

Implementations

impl MessageMetadata

pub fn new() -> Self

Create new empty metadata.

pub fn with_timestamp_now() -> Self

Create metadata with the current timestamp.

pub fn timestamp(self, ts: Duration) -> Self

Set the timestamp.

pub fn source(self, source: impl Into<String>) -> Self

Set the source.

pub fn partition(self, partition: u32) -> Self

Set the partition.

pub fn offset(self, offset: u64) -> Self

Set the offset.

pub fn key(self, key: impl Into<String>) -> Self

Set the key.

pub fn header(self, name: impl Into<String>, value: impl Into<String>) -> Self

Add a header.

pub fn get_header(&self, name: &str) -> Option<&str>

Get a header by name.

Trait Implementations

impl Clone for MessageMetadata

fn clone(&self) -> MessageMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageMetadata

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

Formats the value using the given formatter.

impl Default for MessageMetadata

fn default() -> MessageMetadata

Returns the “default value” for a type.