Struct TopicReaderMessage 

#[non_exhaustive]
pub struct TopicReaderMessage {
    pub seq_no: i64,
    pub created_at: Option<SystemTime>,
    pub offset: i64,
    pub written_at: SystemTime,
    pub uncompressed_size: i64,
    /* private fields */
}

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

seq_no: i64

created_at: Option<SystemTime>

offset: i64

written_at: SystemTime

uncompressed_size: i64

Implementations

impl TopicReaderMessage

pub async fn read_and_take(&mut self) -> YdbResult<Option<Vec<u8>>>

pub fn get_producer_id(&self) -> &str

pub fn get_commit_marker(&self) -> TopicReaderCommitMarker

pub fn get_topic(&self) -> &str

pub fn get_partition_id(&self) -> i64