From 0bf67f9b07a648124f76e31fca56771cf5ff7ad4 Mon Sep 17 00:00:00 2001 From: Adrian Fernandez De La Torre Date: Mon, 8 Sep 2025 16:12:49 +0200 Subject: [PATCH] OTEL provider - allow to use source-revision populated by a ks Signed-off-by: Adrian Fernandez De La Torre --- internal/notifier/otel.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/internal/notifier/otel.go b/internal/notifier/otel.go index 769d7b80c..d751561db 100644 --- a/internal/notifier/otel.go +++ b/internal/notifier/otel.go @@ -131,6 +131,7 @@ func (t *OTLPTracer) Post(ctx context.Context, event eventv1.Event) error { // Extract revision from event metadata revision := getRevision(event.Metadata) + logger.Info("Revision ID (former part of Trace ID)", revision) // Create TraceProvider tp := sdktrace.NewTracerProvider( @@ -146,7 +147,7 @@ func (t *OTLPTracer) Post(ctx context.Context, event eventv1.Event) error { ) // Generate traceID - logger.V(1).Info("Generating trace IDs", "alertUID", string(alert.UID), "revision", revision) + logger.Info("Generating trace IDs", "alertUID", string(alert.UID), "revision", revision) var traceID trace.TraceID traceIDStr := generateID(string(alert.UID), revision) copy(traceID[:], traceIDStr[:16]) @@ -235,7 +236,9 @@ func getRevision(eventMetadata map[string]string) string { ociDigest, hasOCI := eventMetadata["oci-digest"] appVersion, hasApp := eventMetadata["app-version"] - if hasOCI && hasApp { + if rev, hasRev := eventMetadata["source-revision"]; hasRev { + revision = rev + } else if hasOCI && hasApp { revision = appVersion + "@" + ociDigest } else if rev, hasRev := eventMetadata["revision"]; hasRev { revision = rev