Struct nakadi_types::event::publishable::EventMetaDataPub

pub struct EventMetaDataPub {
    pub eid: EventId,
    pub event_type: Option<EventTypeName>,
    pub occurred_at: DateTime<Utc>,
    pub parent_eids: Vec<EventId>,
    pub partition: Option<PartitionId>,
    pub flow_id: Option<FlowId>,
}

Metadata of an event

See also Nakadi Manual

Fields

eid: EventId

Identifier of this Event.

event_type: Option<EventTypeName>

The EventType of this Event. This is enriched by Nakadi on reception of the Event based on the endpoint where the Producer sent the Event to.

If provided MUST match the endpoint. Failure to do so will cause rejection of the Event.

occurred_at: DateTime<Utc>

Timestamp of creation of the Event generated by the producer.

parent_eids: Vec<EventId>

Event identifier of the Event that caused the generation of this Event. Set by the producer.

partition: Option<PartitionId>

Indicates the partition assigned to this Event.

Required to be set by the client if partition strategy of the EventType is ‘user_defined’.

flow_id: Option<FlowId>

Implementations

impl EventMetaDataPub

pub fn new<T: Into<EventId>>(eid: T) -> Self

pub fn random_eid() -> Self

pub fn event_type<T: Into<EventTypeName>>(self, v: T) -> Self

pub fn occurred_at<T: Into<DateTime<Utc>>>(self, v: T) -> Self

pub fn parent_eid<T: Into<EventId>>(self, v: T) -> Self

pub fn partition<T: Into<PartitionId>>(self, v: T) -> Self

pub fn flow_id<T: Into<FlowId>>(self, v: T) -> Self

Trait Implementations

impl Clone for EventMetaDataPub

fn clone(&self) -> EventMetaDataPub

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for EventMetaDataPub

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

Formats the value using the given formatter.

impl From<EventMetaData> for EventMetaDataPub

fn from(m: EventMetaData) -> Self

Performs the conversion.

impl Serialize for EventMetaDataPub

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

Serialize this value into the given Serde serializer.