Struct StreamChangelogEntry 

pub struct StreamChangelogEntry {
    pub source_id: u16,
    pub op: u8,
    pub sequence: u64,
    pub watermark: i64,
    /* private fields */
}

A single changelog entry — fixed 24 bytes, no heap allocation.

Layout (repr(C)):

[source_id: u16][op: u8][padding: u8][reserved: u32][sequence: u64][watermark: i64]

Fields

source_id: u16

Source identifier (compact).

op: u8

Operation type.

sequence: u64

Sequence number at time of operation.

watermark: i64

Watermark value at time of operation.

Implementations

impl StreamChangelogEntry

pub fn new( source_id: u16, op: StreamChangeOp, sequence: u64, watermark: i64, ) -> Self

Creates a new changelog entry.

pub fn op_type(&self) -> Option<StreamChangeOp>

Returns the operation type.

Trait Implementations

impl Clone for StreamChangelogEntry

fn clone(&self) -> StreamChangelogEntry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamChangelogEntry

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

Formats the value using the given formatter.

impl PartialEq for StreamChangelogEntry

fn eq(&self, other: &StreamChangelogEntry) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for StreamChangelogEntry

impl Eq for StreamChangelogEntry

impl StructuralPartialEq for StreamChangelogEntry