Struct Event 

pub struct Event<P = Payload> { /* private fields */ }

Implementations

impl<P> Event<P>

pub fn new( id: EventId, organization: OrganizationId, namespace: Namespace, topic: Topic, key: EventKey, payload: P, metadata: Metadata, timestamp: DateTime<Utc>, version: u64, parent_id: Option<EventId>, correlation_id: Option<EventKey>, causation_id: Option<EventKey>, ) -> Result<Self>

pub fn builder( organization: impl Into<String>, namespace: impl Into<String>, topic: impl Into<String>, key: impl Into<String>, payload: P, ) -> Result<EventBuilder<P>>

pub fn create( organization: impl Into<String>, namespace: impl Into<String>, topic: impl Into<String>, key: impl Into<String>, payload: P, ) -> Result<Self>

pub fn with_metadata(self, metadata: Metadata) -> Self

pub fn id(&self) -> EventId

pub fn organization(&self) -> &OrganizationId

pub fn namespace(&self) -> &Namespace

pub fn topic(&self) -> &Topic

pub fn payload(&self) -> &P

pub fn into_payload(self) -> P

pub fn metadata(&self) -> &Metadata

pub fn timestamp(&self) -> DateTime<Utc>

pub fn version(&self) -> u64

pub fn key(&self) -> &EventKey

pub fn parent_id(&self) -> Option<EventId>

pub fn correlation_id(&self) -> Option<&EventKey>

pub fn causation_id(&self) -> Option<&EventKey>

pub fn map_payload<Q, F>(self, f: F) -> Event<Q>

where F: FnOnce(P) -> Q,

pub fn try_map_payload<Q, F>(self, f: F) -> Result<Event<Q>>

where F: FnOnce(P) -> Result<Q>,

pub fn encode_payload<C>(&self, codec: &C) -> Result<Event<Payload>>

where C: PayloadCodec<P>,

impl Event<Payload>

pub fn decode_payload<P, C>(self, codec: &C) -> Result<Event<P>>

where C: PayloadCodec<P>,

Trait Implementations

impl<P: Clone> Clone for Event<P>

fn clone(&self) -> Event<P>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P: Debug> Debug for Event<P>

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

Formats the value using the given formatter.