Struct StreamEvent 

pub struct StreamEvent<T> {
    pub timestamp: SystemTime,
    pub payload: T,
    pub sequence: u64,
}

A single typed event in the stream, carrying a wall-clock timestamp and a monotonically increasing sequence number.

Fields

timestamp: SystemTime

Wall-clock time at which the event occurred.

payload: T

Application payload.

sequence: u64

Sequence number, strictly increasing within a stream.

Implementations

impl<T> StreamEvent<T>

pub fn new(timestamp: SystemTime, payload: T, sequence: u64) -> Self

Construct a new StreamEvent.

Trait Implementations

impl<T: Clone> Clone for StreamEvent<T>

fn clone(&self) -> StreamEvent<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for StreamEvent<T>

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

Formats the value using the given formatter.