/// Records the (unreliably) estimated duration to induct one ingress
/// message.
Records the (unreliably) estimated duration to induct one ingress
message.
Records the ( unreliably ) estimated duration to induct one ingress message .
fn observe_unreliable_induct_ingress_message_duration(
        &self,
        status: &str,
        ingress_expiry: Time,
    ) {
        let current_expiry_time = current_time_and_expiry_time().1;
        let delta_in_nanos = if current_expiry_time <= ingress_expiry {
            Duration::from_secs(0)
        } else {
            current_expiry_time - ingress_expiry
        };
        self.metrics
            .unreliable_induct_ingress_message_duration
            .with_label_values(&[status])
            .observe(delta_in_nanos.as_secs_f64());
    }
fn observe_unreliable_induct_ingress_message_duration ( & self , status : & str , ingress_expiry : Time , ) { let current_expiry_time = current_time_and_expiry_time ( ) . 1 ; let delta_in_nanos = if current_expiry_time <= ingress_expiry { Duration :: from_secs ( 0 ) } else { current_expiry_time - ingress_expiry } ; self . metrics . unreliable_induct_ingress_message_duration . with_label_values ( & [ status ] ) . observe ( delta_in_nanos . as_secs_f64 ( ) ) ; }
Records the (unreliably) estimated duration to induct one ingress
message.
Records the ( unreliably ) estimated duration to induct one ingress message .
&self
status
&str
ingress_expiry
Time