Struct intrepid_model::Event

pub struct Event {
    pub stream_name: String,
    pub kind: EventKind,
    pub data: Bytes,
}

An event in a stream. This is slimmer than the EventRecord type, and is used for most public interactions with events.

Fields

stream_name: String

The name of the stream that the event is in.

kind: EventKind

The kind of event.

data: Bytes

The main data of the event.

Implementations

impl Event

pub fn entry(stream_name: impl AsRef<str>, data: impl Into<Bytes>) -> Self

Create a new entry event.

pub fn read_marker( stream_name: impl AsRef<str>, subscriber_name: impl AsRef<str>, position: i64, ) -> Self

Create a new read marker event.

pub async fn publish(&self, repo: &impl EventRepo) -> Result<(), EventRepoError>

Publish the event to the given repository.

Trait Implementations

impl Clone for Event

fn clone(&self) -> Event

Returns a copy of the value.

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

Performs copy-assignment from source.

impl From<Event> for EventRecord

fn from(event: Event) -> Self

Converts to this type from the input type.

impl From<Event> for EventLog

fn from(event: Event) -> Self

Converts to this type from the input type.

impl IntoCache for Event

fn into_cache(self) -> CacheRecord

Consume the type, producing a CacheRecord