Struct EventMetadata 

pub struct EventMetadata {
    pub identifier: String,
    pub event_type: EventType,
    pub date_created: DateTime<Utc>,
    pub date_published: Option<DateTime<Utc>>,
    pub partition: Option<u32>,
    pub offset: Option<u64>,
}

Event metadata for articles.

Tracks events through the Wikimedia Enterprise system. The partition and offset fields enable resuming streams after disconnections.

Resuming Streams

// Store the last processed offset for each partition
let offsets: HashMap<u32, u64> = load_checkpoints();

// When reconnecting, pass these offsets
client.connect_with_offsets(offsets).await?;

Fields

identifier: String

Event UUID (for tracking through the system)

event_type: EventType

Event type (update, delete, visibility-change)

date_created: DateTime<Utc>

Event creation timestamp (when entered Enterprise system)

date_published: Option<DateTime<Utc>>

Event publication timestamp (Realtime API only)

partition: Option<u32>

Partition number (Realtime API only, for resume)

offset: Option<u64>

Offset within partition (Realtime API only, for resume)

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.

impl<'de> Deserialize<'de> for EventMetadata

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for EventMetadata

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

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for EventMetadata