Struct StreamRecord 

pub struct StreamRecord {
    pub sequence_number: u64,
    pub event_type: StreamEventType,
    pub key: Key,
    pub old_image: Option<Item>,
    pub new_image: Option<Item>,
    pub timestamp: i64,
}

A stream record capturing a single item change

Fields

sequence_number: u64

Sequence number (globally unique, monotonically increasing)

event_type: StreamEventType

Type of change event

key: Key

The key of the modified item

old_image: Option<Item>

The item before modification (if applicable and view type includes it)

new_image: Option<Item>

The item after modification (if applicable and view type includes it)

timestamp: i64

Approximate timestamp when the change occurred (milliseconds since epoch)

Implementations

impl StreamRecord

pub fn insert( sequence_number: u64, key: Key, new_image: Item, view_type: StreamViewType, ) -> Self

Create an INSERT record

pub fn modify( sequence_number: u64, key: Key, old_image: Item, new_image: Item, view_type: StreamViewType, ) -> Self

Create a MODIFY record

pub fn remove( sequence_number: u64, key: Key, old_image: Item, view_type: StreamViewType, ) -> Self

Create a REMOVE record

Trait Implementations

impl Clone for StreamRecord

fn clone(&self) -> StreamRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamRecord

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamRecord

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.