fix: improve svm landing time metric

auction-server/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "auction-server"
-version = "0.17.0"
+version = "0.17.1"
 edition = "2021"
 license-file = "license.txt"
 

auction-server/src/auction/service/auction_manager.rs

@@ -20,6 +20,7 @@ use {
             self,
             service::get_live_opportunities::GetLiveOpportunitiesInput,
         },
+        server::TRANSACTION_LANDING_TIME_SVM_METRIC,
     },
     anyhow::Result,
     axum::async_trait,
@@ -678,8 +679,7 @@ impl Service<Svm> {
     }
 
     #[tracing::instrument(skip_all, fields(bid_id, total_tries, tx_hash))]
-    async fn blocking_send_transaction(&self, bid: entities::Bid<Svm>) {
-        let start = Instant::now();
+    async fn blocking_send_transaction(&self, bid: entities::Bid<Svm>, start: Instant) {
         let mut result_label = METRIC_LABEL_EXPIRED;
         let signature = bid.chain_data.transaction.signatures[0];
         tracing::Span::current().record("bid_id", bid.id.to_string());
@@ -726,7 +726,7 @@ impl Service<Svm> {
             // but this is rare as we retry for 60 seconds and blockhash expires after 60 seconds
             ("result", result_label.to_string()),
         ];
-        metrics::histogram!("transaction_landing_time_seconds_svm", &labels)
+        metrics::histogram!(TRANSACTION_LANDING_TIME_SVM_METRIC, &labels)
             .record(start.elapsed().as_secs_f64());
 
         tracing::Span::current().record("total_tries", retry_count + 1);
@@ -738,18 +738,19 @@ impl Service<Svm> {
         bid: &entities::Bid<Svm>,
     ) -> solana_client::client_error::Result<Signature> {
         tracing::Span::current().record("bid_id", bid.id.to_string());
+        let start = Instant::now();
         let tx = &bid.chain_data.transaction;
-        self.send_transaction_to_network(&bid.chain_data.transaction)
-            .await?;
+        self.send_transaction_to_network(tx).await?;
         self.config
             .chain_config
             .simulator
             .add_pending_transaction(tx)
             .await;
+
         self.task_tracker.spawn({
             let (service, bid) = (self.clone(), bid.clone());
             async move {
-                service.blocking_send_transaction(bid).await;
+                service.blocking_send_transaction(bid, start).await;
             }
         });
         Ok(tx.signatures[0])

auction-server/src/server.rs

@@ -135,8 +135,20 @@ async fn fetch_access_tokens(db: &PgPool) -> HashMap<models::AccessTokenToken, m
         .collect()
 }
 
+pub const TRANSACTION_LANDING_TIME_SVM_METRIC: &str = "transaction_landing_time_seconds_svm";
+const TRANSACTION_LANDING_TIME_SVM_BUCKETS: &[f64; 14] = &[
+    0.1, 0.25, 0.5, 0.75, 1.0, 1.25, 1.5, 1.75, 2.0, 2.25, 2.5, 3.75, 5.0, 10.0,
+];
+
 pub fn setup_metrics_recorder() -> Result<PrometheusHandle> {
     PrometheusBuilder::new()
+        .set_buckets_for_metric(
+            axum_prometheus::metrics_exporter_prometheus::Matcher::Full(
+                TRANSACTION_LANDING_TIME_SVM_METRIC.to_string(),
+            ),
+            TRANSACTION_LANDING_TIME_SVM_BUCKETS,
+        )
+        .unwrap()
         .set_buckets(SECONDS_DURATION_BUCKETS)
         .unwrap()
         .install_recorder()