From 552300d437ed3a3c3ecf20049b0f96eb2a9a13c1 Mon Sep 17 00:00:00 2001 From: rtkay123 Date: Fri, 15 Aug 2025 21:05:36 +0200 Subject: feat(exec): get config --- crates/configuration/src/state.rs | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) (limited to 'crates/configuration/src') diff --git a/crates/configuration/src/state.rs b/crates/configuration/src/state.rs index de58d4b..d8f22d5 100644 --- a/crates/configuration/src/state.rs +++ b/crates/configuration/src/state.rs @@ -3,9 +3,11 @@ mod routing; mod rule; use async_nats::jetstream::Context; +use opentelemetry_semantic_conventions::attribute; use sqlx::PgPool; use std::{ops::Deref, sync::Arc}; -use tracing::{instrument, trace}; +use tracing::{Instrument, info_span, instrument, trace}; +use tracing_opentelemetry::OpenTelemetrySpanExt; use warden_core::configuration::ReloadEvent; use warden_stack::{Configuration, cache::RedisManager, redis::AsyncCommands}; @@ -84,10 +86,16 @@ pub async fn publish_reload( event: ReloadEvent, ) -> Result<(), tonic::Status> { trace!("publishing reload event"); + + let span = info_span!("reload config"); + span.set_attribute(attribute::MESSAGING_SYSTEM, "nats"); + span.set_attribute("otel.kind", "producer"); + state .services .jetstream .publish(format!("{prefix}.reload"), event.as_str_name().into()) + .instrument(span) .await .map_err(|e| tonic::Status::internal(e.to_string()))?; -- cgit v1.2.3