Struct EventMetadata 

pub struct EventMetadata {
    pub source: String,
    pub timestamp: Instant,
    pub key: Option<String>,
    pub backend_specific: Option<Box<dyn BackendMetadata>>,
}

Generic event metadata that works across all backends

Fields

source: String

timestamp: Instant

key: Option<String>

backend_specific: Option<Box<dyn BackendMetadata>>

Implementations

impl EventMetadata

Extension methods for easy access to backend-specific metadata

pub fn new( source: String, timestamp: Instant, key: Option<String>, backend_specific: Option<Box<dyn BackendMetadata>>, ) -> Self

Create new metadata with backend-specific data

pub fn kafka_metadata(&self) -> Option<&KafkaMetadata>

Get Kafka-specific metadata if available

pub fn redis_metadata(&self) -> Option<&RedisMetadata>

Get Redis-specific metadata if available

impl EventMetadata

pub fn key_as_string(&self) -> Option<String>

Get the key as a UTF-8 string if possible

pub fn key_display(&self) -> Option<String>

Get a human-readable representation of the key

Trait Implementations

impl Clone for EventMetadata

fn clone(&self) -> EventMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventMetadata

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

Formats the value using the given formatter.