Struct hedwig::Message

pub struct Message<D, T> {
    pub id: Uuid,
    pub metadata: Metadata,
    pub schema: String,
    pub data: D,
    pub format_version: Version,
    pub data_type: T,
    pub data_schema_version: Version,
    // some fields omitted
}

Message represents an instance of a message on the message bus.

Fields

id: Uuid

Message identifier

metadata: Metadata

Metadata associated with the message

schema: String

Message schema, e.g. https://hedwig.standard.ai/schemas#/schemas/user.created/1.0

data: D

Associated message data

format_version: Version

Format version for the message container

data_type: T

Type of data represented by this message

data_schema_version: Version

Schema version of the data object. This should follow semver.

Methods

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

pub fn with_headers(&mut self, headers: Headers) -> &mut Self

Add custom headers to the message. This may be used to track request_id, for example.

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

Add custom id to the message. If not provided, a new uuid v4 is used.

Trait Implementations

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: 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: Debug, T: Debug> Debug for Message<D, T>

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

Formats the value using the given formatter.

impl<D, T> Serialize for Message<D, T> where
    D: Serialize, 

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

Serialize this value into the given Serde serializer.