diff options
| author | rtkay123 <dev@kanjala.com> | 2025-08-15 21:05:36 +0200 |
|---|---|---|
| committer | rtkay123 <dev@kanjala.com> | 2025-08-15 21:05:36 +0200 |
| commit | 552300d437ed3a3c3ecf20049b0f96eb2a9a13c1 (patch) | |
| tree | fd54a21b63cdf3ab11b74972c980b42d9024e65e /crates/router/src/processor | |
| parent | 1968002d656383069a386bd874c9f0cc83e3116e (diff) | |
| download | warden-552300d437ed3a3c3ecf20049b0f96eb2a9a13c1.tar.bz2 warden-552300d437ed3a3c3ecf20049b0f96eb2a9a13c1.zip | |
feat(exec): get config
Diffstat (limited to 'crates/router/src/processor')
| -rw-r--r-- | crates/router/src/processor/publish.rs | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/crates/router/src/processor/publish.rs b/crates/router/src/processor/publish.rs index 277b674..3158e4d 100644 --- a/crates/router/src/processor/publish.rs +++ b/crates/router/src/processor/publish.rs @@ -32,11 +32,13 @@ pub(crate) async fn to_rule( propagator.inject_context(&cx, &mut injector::HeaderMap(&mut headers)) }); - let span = info_span!("nats.publish"); + let span = info_span!("nats.publish", "otel.kind" = "producer"); span.set_attribute( attribute::MESSAGING_DESTINATION_SUBSCRIPTION_NAME, subject.to_string(), ); + span.set_attribute(attribute::MESSAGING_SYSTEM, "nats"); + state .services .jetstream |