Trait mz_storage_client::types::sources::SourceTimestamp

pub trait SourceTimestamp: Timestamp + Refines<()> + Display {
    // Required methods
    fn from_compat_ts(pid: PartitionId, offset: MzOffset) -> Self;
    fn try_into_compat_ts(&self) -> Option<(PartitionId, MzOffset)>;
    fn encode_row(&self) -> Row;
    fn decode_row(row: &Row) -> Self;
}

Required Methods

fn from_compat_ts(pid: PartitionId, offset: MzOffset) -> Self

fn try_into_compat_ts(&self) -> Option<(PartitionId, MzOffset)>

fn encode_row(&self) -> Row

fn decode_row(row: &Row) -> Self

Implementations on Foreign Types

impl SourceTimestamp for Partitioned<i32, MzOffset>

fn from_compat_ts(pid: PartitionId, offset: MzOffset) -> Self

fn try_into_compat_ts(&self) -> Option<(PartitionId, MzOffset)>

fn encode_row(&self) -> Row

fn decode_row(row: &Row) -> Self

Implementors

impl SourceTimestamp for MzOffset