Struct ComputeMessageStatsResponse 

pub struct ComputeMessageStatsResponse {
    pub message_bytes: Option<i64>,
    pub message_count: Option<i64>,
    pub minimum_event_time: Option<DateTime<Utc>>,
    pub minimum_publish_time: Option<DateTime<Utc>>,
}

Response containing stats for messages in the requested topic and partition.

Activities

This type is used in activities, which are methods you may call on this type or where this type is involved in. The list links the activity name, along with information about where it is used (one of request and response).

• projects locations topics compute message stats topic stats (response)

Fields

message_bytes: Option<i64>

The number of quota bytes accounted to these messages.

message_count: Option<i64>

The count of messages.

minimum_event_time: Option<DateTime<Utc>>

The minimum event timestamp across these messages. For the purposes of this computation, if a message does not have an event time, we use the publish time. The timestamp will be unset if there are no messages.

minimum_publish_time: Option<DateTime<Utc>>

The minimum publish timestamp across these messages. Note that publish timestamps within a partition are not guaranteed to be non-decreasing. The timestamp will be unset if there are no messages.

Trait Implementations

impl Clone for ComputeMessageStatsResponse

fn clone(&self) -> ComputeMessageStatsResponse

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ComputeMessageStatsResponse

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

Formats the value using the given formatter.

impl Default for ComputeMessageStatsResponse

fn default() -> ComputeMessageStatsResponse

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ComputeMessageStatsResponse

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ComputeMessageStatsResponse

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ResponseResult for ComputeMessageStatsResponse