From 8c35de11e5b92e9e62dcd2a05f83c28d677bd1b7 Mon Sep 17 00:00:00 2001 From: Grzegorz Uriasz Date: Wed, 22 Apr 2026 19:04:51 +0200 Subject: [PATCH] how many subs per second? --- crates/corro-agent/src/api/public/pubsub.rs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/crates/corro-agent/src/api/public/pubsub.rs b/crates/corro-agent/src/api/public/pubsub.rs index 13f95bda8..4cd30115c 100644 --- a/crates/corro-agent/src/api/public/pubsub.rs +++ b/crates/corro-agent/src/api/public/pubsub.rs @@ -12,6 +12,7 @@ use corro_types::{ pubsub::{MatcherCreated, MatcherError, MatcherHandle, NormalizeStatementError, SubsManager}, sqlite::SqlitePoolError, }; +use metrics::counter; use rusqlite::Connection; use serde::Deserialize; use tokio::{ @@ -42,6 +43,7 @@ pub async fn api_v1_sub_by_id( axum::extract::Path(id): axum::extract::Path, axum::extract::Query(params): axum::extract::Query, ) -> impl IntoResponse { + counter!("corro.api.subs.count", "protocol" => "http").increment(1); sub_by_id(agent.subs_manager(), id, params, &bcast_cache, tripwire).await } @@ -682,6 +684,7 @@ pub async fn api_v1_subs( axum::extract::Query(params): axum::extract::Query, axum::extract::Json(stmt): axum::extract::Json, ) -> impl IntoResponse { + counter!("corro.api.subs.count", "protocol" => "http").increment(1); let stmt = match expand_sql(&agent, &stmt).await { Ok(stmt) => stmt, Err(e) => return hyper::Response::from(e),