Struct eventstore::RecordedEvent

source · [−]

pub struct RecordedEvent {
    pub stream_id: String,
    pub id: Uuid,
    pub revision: u64,
    pub event_type: String,
    pub data: Bytes,
    pub metadata: HashMap<String, String>,
    pub custom_metadata: Bytes,
    pub is_json: bool,
    pub position: Position,
}

Expand description

Represents a previously written event.

Fields

stream_id: String

The event stream that events belongs to.

id: Uuid

Unique identifier representing this event.

revision: u64

Number of this event in the stream.

event_type: String

Type of this event.

data: Bytes

Payload of this event.

metadata: HashMap<String, String>

Representing the metadata associated with this event.

custom_metadata: Bytes

Representing the user-defined metadata associated with this event.

is_json: bool

Indicates wheter the content is internally marked as JSON.

position: Position

An event position in the $all stream.

Implementations

impl RecordedEvent

pub fn as_json<'a, T>(&'a self) -> Result<T> where
T: Deserialize<'a>,

Tries to decode this event payload as a JSON object.

Trait Implementations

impl Debug for RecordedEvent

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

Formats the value using the given formatter. Read more

Auto Trait Implementations

impl RefUnwindSafe for RecordedEvent

impl Send for RecordedEvent

impl Sync for RecordedEvent

impl Unpin for RecordedEvent

impl UnwindSafe for RecordedEvent

Blanket Implementations

impl<T> Any for T where
T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

const: unstable · source

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T where
U: From<T>,

const: unstable · source

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request

impl<T, U> TryFrom<U> for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more