Struct Record

pub struct Record<T> {
    pub data: T,
    pub timestamp: i64,
}

Record represents a single data record in the stream

Fields

data: T

The actual data payload

timestamp: i64

Timestamp of the record (in milliseconds)

Implementations

impl<T> Record<T>

pub fn new(data: T) -> Self

Create a new record with the current timestamp

pub fn with_timestamp(data: T, timestamp: i64) -> Self

Create a new record with a specific timestamp

Trait Implementations

impl<T: Clone> Clone for Record<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Record<T>

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

Formats the value using the given formatter.