Struct StreamEvent 

pub struct StreamEvent {
    pub key: String,
    pub value: String,
    pub topic: String,
    pub timestamp_ms: u64,
    pub headers: HashMap<String, String>,
}

A stream event with a key, value, topic, timestamp, and optional headers.

Fields

key: String

The event key (partition routing hint or entity identifier).

value: String

The event payload value.

topic: String

The topic (channel) this event was published on.

timestamp_ms: u64

Timestamp in milliseconds since the Unix epoch.

headers: HashMap<String, String>

Arbitrary key-value metadata headers.

Implementations

impl StreamEvent

pub fn new(key: &str, value: &str, topic: &str, timestamp_ms: u64) -> Self

Create a new event with no headers.

pub fn with_header( self, header_key: impl Into<String>, header_val: impl Into<String>, ) -> Self

Builder-style method to add a header.

Trait Implementations

impl Clone for StreamEvent

fn clone(&self) -> StreamEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamEvent

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

Formats the value using the given formatter.

impl PartialEq for StreamEvent

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