Struct EventStoreReceive 

pub struct EventStoreReceive {
    pub id: String,
    pub sequence: u64,
    pub timestamp: i64,
    pub channel: String,
    pub metadata: String,
    pub body: Vec<u8>,
    pub tags: HashMap<String, String>,
}

A persistent event received from an Events Store subscription callback.

Delivered to the on_event closure passed to KubemqClient::subscribe_to_events_store().

Fields

id: String

Server-assigned event identifier.

sequence: u64

Monotonically increasing sequence number within the channel.

timestamp: i64

Server timestamp (Unix nanoseconds) when the event was persisted.

channel: String

The channel this event was published to.

metadata: String

UTF-8 metadata attached by the publisher.

body: Vec<u8>

Message payload bytes.

tags: HashMap<String, String>

Key-value tags attached by the publisher.

Trait Implementations

impl Clone for EventStoreReceive

fn clone(&self) -> EventStoreReceive

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventStoreReceive

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

Formats the value using the given formatter.