Struct MetricsRollupData 

pub struct MetricsRollupData {

    pub bucket_duration_s: Option<i16>,
    pub neighbor_count_avg: Option<f32>,
    pub neighbor_count_max: Option<i32>,
    pub neighbor_count_p50: Option<i32>,
    pub ack_pending_avg: Option<f32>,
    pub ack_pending_max: Option<i32>,
    pub retry_queue_total_avg: Option<f32>,
    pub retry_queue_total_max: Option<i32>,
    pub retry_queue_critical_max: Option<i32>,
    pub transport_time_ms: Option<TransportTimeMs>,
    pub is_local_relay_duration_s: Option<i32>,
    pub current_transport_at_bucket_end: Option<String>,
    pub sends_attempted: Option<i32>,
    pub sends_succeeded: Option<i32>,
    pub sends_failed: Option<i32>,
    pub bytes_sent: Option<i64>,
    pub bytes_received: Option<i64>,
}

mesh_metrics_rollup (plan §2.1, Appendix A). Wire→column renames: retry_queue_critical_count_max→retry_queue_critical_max, the sends_*_sum/bytes_*_sum suffixes are dropped, and transport_time_ms is flattened. bucket_start_ms is on the wire but maps to the row ts (taken from the envelope’s ts_ms), so it has no field here.

Fields

bucket_duration_s: Option<i16>

neighbor_count_avg: Option<f32>

neighbor_count_max: Option<i32>

neighbor_count_p50: Option<i32>

ack_pending_avg: Option<f32>

ack_pending_max: Option<i32>

retry_queue_total_avg: Option<f32>

retry_queue_total_max: Option<i32>

retry_queue_critical_max: Option<i32>

transport_time_ms: Option<TransportTimeMs>

is_local_relay_duration_s: Option<i32>

current_transport_at_bucket_end: Option<String>

sends_attempted: Option<i32>

sends_succeeded: Option<i32>

sends_failed: Option<i32>

bytes_sent: Option<i64>

bytes_received: Option<i64>

Trait Implementations

impl Clone for MetricsRollupData

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MetricsRollupData

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

Formats the value using the given formatter.

impl Default for MetricsRollupData

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MetricsRollupData

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MetricsRollupData

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

where __S: Serializer,

Serialize this value into the given Serde serializer.