Struct hedwig::Message

pub struct Message<D, T> { /* fields omitted */ }

A message builder.

Methods

impl<D, T> Message<D, T>

pub fn new(data_type: T, data_schema_version: Version, data: D) -> Self

Construct a new message.

pub fn headers(self, headers: HashMap<String, String>) -> Self

Overwrite the header map associated with the message.

This may be used to track the request_id, for example.

pub fn header<H, V>(self, header: H, value: V) -> Self where
    H: Into<String>,
    V: Into<String>, 

Add a custom header to the message.

This may be used to track the request_id, for example.

pub fn id(self, id: Uuid) -> Self

Add custom id to the message. If not provided, a random UUID is generated.

Trait Implementations

impl<D: Clone, T: Clone> Clone for Message<D, T>

fn clone(&self) -> Message<D, T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<D: PartialEq, T: PartialEq> PartialEq<Message<D, T>> for Message<D, T>

fn eq(&self, other: &Message<D, T>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Message<D, T>) -> bool

This method tests for !=.

impl<D: Debug, T: Debug> Debug for Message<D, T>

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

Formats the value using the given formatter.