Struct Message 

pub struct Message<T> {
    pub topic: String,
    pub key: Option<String>,
    pub payload: T,
    pub headers: HashMap<String, String>,
    pub timestamp: DateTime<Utc>,
    pub partition: Option<i32>,
    pub offset: Option<i64>,
}

A generic message that can be sent to or received from a message broker.

Fields

topic: String

The topic or channel the message belongs to.

key: Option<String>

Optional partitioning key.

payload: T

The message payload.

headers: HashMap<String, String>

Arbitrary key-value headers attached to the message.

timestamp: DateTime<Utc>

Timestamp when the message was created.

partition: Option<i32>

The partition the message was sent to or read from.

offset: Option<i64>

The offset within the partition.

Implementations

impl<T> Message<T>

pub fn new(topic: impl Into<String>, payload: T) -> Self

Create a new message for the given topic with the provided payload.

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

Set the partitioning key.

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

Attach a single header.

pub fn with_message_id(self) -> Self

Attach a unique message-id header.

Trait Implementations

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

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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

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

Formats the value using the given formatter.

impl<T: Send + Sync + 'static> Sink<Message<T>> for ProducerSink<T>

async fn send(&self, input: Message<T>) -> AppResult<()>

Send a single item downstream.

impl<T: Send + Sync + Clone + 'static> Stream<(), Message<T>> for ConsumerStream<T>

async fn execute(&self, _input: ()) -> AppResult<BoxStream<Message<T>>>

Execute the request and return a stream of responses.