Struct TopicMetadata 

pub struct TopicMetadata {
    pub topic: String,
    pub message_count: Option<usize>,
    pub last_update_ms: Option<u64>,
    pub first_timestamp_ms: Option<u64>,
    pub last_timestamp_ms: Option<u64>,
}

Topic metadata extracted from Redis stream info

Fields

topic: String

Topic path

message_count: Option<usize>

Number of messages in the stream

last_update_ms: Option<u64>

Timestamp of last message (milliseconds since epoch)

first_timestamp_ms: Option<u64>

Timestamp of first message (milliseconds since epoch)

last_timestamp_ms: Option<u64>

Timestamp of last message (milliseconds since epoch)

Implementations

impl TopicMetadata

pub fn new(topic: String) -> Self

Create new topic metadata

pub fn with_message_count(self, count: usize) -> Self

Set message count

pub fn with_last_update(self, timestamp_ms: u64) -> Self

Set last update timestamp

pub fn with_timestamp_range(self, first_ms: u64, last_ms: u64) -> Self

Set timestamp range

pub fn elapsed_since_last_update(&self) -> Option<u64>

Calculate elapsed time since last update

pub fn calculate_rate(&self) -> Option<f64>

Calculate message rate (messages per second)

pub fn last_update_str(&self) -> Option<String>

Get human-readable last update time

pub fn category(&self) -> String

Get topic category

Trait Implementations

impl Clone for TopicMetadata

fn clone(&self) -> TopicMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TopicMetadata

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

Formats the value using the given formatter.