fix(std): instant elapsed may cause panic (#105)

* fix: instant elapsed may cause panic

* cargo update

* cargo clippy

Author: Eason Gao

Cargo.lock

@@ -6,3 +6,9 @@ pub mod server;
 pub use muta_apm;
 pub use prometheus;
 pub use prometheus_static_metric;
+
+use std::time::{Duration, Instant};
+
+pub fn elapsed(inst: Instant) -> Duration {
+    Instant::now().saturating_duration_since(inst)
+}

common/apm/src/lib.rs

@@ -109,7 +109,7 @@ use proc_macro::TokenStream;
 ///                 .inc();
 ///             common_apm::metrics::api::API_REQUEST_TIME_HISTOGRAM_STATIC
 ///                 .eth_sendRawTransaction
-///                 .observe(common_apm::metrics::duration_to_sec(inst.elapsed()));
+///                 .observe(common_apm::metrics::duration_to_sec(common_apm::elapsed(inst)));
 ///             ret
 ///         })
 ///     }
@@ -132,7 +132,7 @@ use proc_macro::TokenStream;
 ///             .inc();
 ///         common_apm::metrics::api::API_REQUEST_TIME_HISTOGRAM_STATIC
 ///             .net_listening
-///             .observe(common_apm::metrics::duration_to_sec(inst.elapsed()));
+///             .observe(common_apm::metrics::duration_to_sec(common_apm::elapsed(inst)));
 ///         ret
 ///     }
 /// }

common/metrics-derive/src/lib.rs

@@ -40,7 +40,7 @@ pub fn expand_rpc_metrics(attr: TokenStream, func: TokenStream) -> TokenStream {
                     .inc();
                 common_apm::metrics::api::API_REQUEST_TIME_HISTOGRAM_STATIC
                     .#func_ident
-                    .observe(common_apm::metrics::duration_to_sec(inst.elapsed()));
+                    .observe(common_apm::metrics::duration_to_sec(common_apm::elapsed(inst)));
 
                 ret
             })
@@ -65,7 +65,7 @@ pub fn expand_rpc_metrics(attr: TokenStream, func: TokenStream) -> TokenStream {
                 .inc();
             common_apm::metrics::api::API_REQUEST_TIME_HISTOGRAM_STATIC
                 .#func_ident
-                .observe(common_apm::metrics::duration_to_sec(inst.elapsed()));
+                .observe(common_apm::metrics::duration_to_sec(common_apm::elapsed(inst)));
 
             ret
         }