From 0a3508087e04024904f53cd7bd2d0f0fdc9475f1 Mon Sep 17 00:00:00 2001 From: Astro Date: Wed, 9 Aug 2023 02:05:25 +0200 Subject: [PATCH] hunter/worker: add hunter_requests gauges for stream_open_token --- hunter/src/worker.rs | 2 ++ 1 file changed, 2 insertions(+) diff --git a/hunter/src/worker.rs b/hunter/src/worker.rs index a5cdb58..47242f7 100644 --- a/hunter/src/worker.rs +++ b/hunter/src/worker.rs @@ -306,7 +306,9 @@ async fn open_stream( .expect("db.get_token()"); if let Some(token) = &token { let url = format!("https://{}/api/v1/streaming/public?access_token={}", host, urlencoding::encode(token)); + metrics::increment_gauge!("hunter_requests", 1.0, "type" => "stream_open_token"); stream = Feed::stream(client, &url).await; + metrics::decrement_gauge!("hunter_requests", 1.0, "type" => "stream_open_token"); } else { tracing::info!("No working token for {}", host); break;