Enum rdkafka::message::Timestamp

pub enum Timestamp {
    NotAvailable,
    CreateTime(i64),
    LogAppendTime(i64),
}

Timestamp of a Kafka message.

Variants

NotAvailable

Timestamp not available.

CreateTime(i64)

Message creation time.

LogAppendTime(i64)

Log append time.

Implementations

impl Timestamp

pub fn to_millis(self) -> Option<i64>

Convert the timestamp to milliseconds since epoch.

pub fn now() -> Timestamp

Creates a new Timestamp::CreateTime representing the current time.

Trait Implementations

impl Clone for Timestamp

fn clone(&self) -> Timestamp

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Timestamp

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

Formats the value using the given formatter.

impl From<SystemTime> for Timestamp

fn from(system_time: SystemTime) -> Timestamp

Converts to this type from the input type.

impl From<i64> for Timestamp

fn from(system_time: i64) -> Timestamp

Converts to this type from the input type.

impl PartialEq<Timestamp> for Timestamp

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

This method tests for self and other values to be equal, and is used by ==.

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

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

impl Copy for Timestamp

impl Eq for Timestamp

impl StructuralEq for Timestamp

impl StructuralPartialEq for Timestamp