feat(api): export basic counter metrics

Author: ymgyt

crates/synd_api/src/main.rs

@@ -1,15 +1,17 @@
-use synd_o11y::{opentelemetry::OpenTelemetryGuard, tracing_subscriber::otel_metrics};
+use synd_o11y::{
+    opentelemetry::OpenTelemetryGuard,
+    tracing_subscriber::otel_metrics::{self, metrics_event_filter},
+};
 use tracing::{error, info};
 
 use synd_api::{
     args::{self, Args},
     config,
     dependency::Dependency,
     repository::kvsd::ConnectKvsdFailed,
-    serve::{layer::request_metrics::METRICS_TARGET, listen_and_serve},
+    serve::listen_and_serve,
     shutdown::Shutdown,
 };
-use tracing_subscriber::filter::filter_fn;
 
 fn init_tracing() -> Option<OpenTelemetryGuard> {
     use synd_o11y::{
@@ -33,8 +35,7 @@ fn init_tracing() -> Option<OpenTelemetryGuard> {
             None => (None, None),
             Some(endpoint) if endpoint.is_empty() => (None, None),
             Some(endpoint) => {
-                let resource =
-                    synd_o11y::opentelemetry::resource(config::NAME, config::VERSION, "local");
+                let resource = synd_o11y::opentelemetry::resource(config::NAME, config::VERSION);
 
                 tracing::info!(endpoint, ?resource, "Export opentelemetry signals");
 
@@ -58,7 +59,7 @@ fn init_tracing() -> Option<OpenTelemetryGuard> {
                 .with_file(show_src)
                 .with_line_number(show_src)
                 .with_target(show_target)
-                .with_filter(filter_fn(|metadata| metadata.target() != METRICS_TARGET))
+                .with_filter(metrics_event_filter())
                 .and_then(opentelemetry_layers)
                 .with_filter(
                     EnvFilter::try_from_default_env()

crates/synd_api/src/serve/layer/request_metrics.rs

@@ -6,10 +6,8 @@ use std::{
 
 use axum::{extract::Request, response::Response};
 use futures_util::Future;
+use synd_o11y::metric;
 use tower::{Layer, Service};
-use tracing::Level;
-
-pub const METRICS_TARGET: &str = "metrics";
 
 #[derive(Clone)]
 pub struct RequestMetricsLayer {}
@@ -55,7 +53,7 @@ where
             let response = this.inner.call(req).await.unwrap();
             let status = response.status().as_u16();
 
-            tracing::event!(target: METRICS_TARGET, Level::INFO, monotonic_counter.request = 1, path, status);
+            metric!(monotonic_counter.request = 1, path, status);
 
             Ok(response)
         })

crates/synd_api/src/usecase/mod.rs

@@ -18,7 +18,7 @@ pub mod authorize;
 use std::{future::Future, sync::Arc};
 
 use synd_feed::feed::cache::FetchCachedFeed;
-use synd_o11y::{audit, tracing_subscriber::audit::Audit};
+use synd_o11y::{audit, metric, tracing_subscriber::audit::Audit};
 
 use crate::{
     principal::Principal,
@@ -113,10 +113,12 @@ impl Runtime {
 
         {
             let user_id = principal.user_id().unwrap_or("?");
+            let operation = uc.audit_operation();
             audit!(
                 { Audit::USER_ID } = user_id,
-                { Audit::OPERATION } = uc.audit_operation(),
+                { Audit::OPERATION } = operation,
             );
+            metric!(monotonic_counter.usecase = 1, operation);
         }
 
         let principal = match self.authorizer.authorize(principal, &uc, &input).await {