From 4db983ce042a1e8b06ec08d9e3e2700020248cb2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Juraci=20Paix=C3=A3o=20Kr=C3=B6hling?= Date: Fri, 30 Jul 2021 15:11:02 +0200 Subject: [PATCH] Add auth data to logging exporter MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Juraci Paixão Kröhling --- exporter/loggingexporter/logging_exporter.go | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/exporter/loggingexporter/logging_exporter.go b/exporter/loggingexporter/logging_exporter.go index daf0e49a95a0..fe0d4d170e62 100644 --- a/exporter/loggingexporter/logging_exporter.go +++ b/exporter/loggingexporter/logging_exporter.go @@ -23,6 +23,7 @@ import ( "go.opentelemetry.io/collector/component" "go.opentelemetry.io/collector/config" + "go.opentelemetry.io/collector/config/configauth" "go.opentelemetry.io/collector/consumer" "go.opentelemetry.io/collector/exporter/exporterhelper" "go.opentelemetry.io/collector/internal/otlptext" @@ -38,7 +39,19 @@ type loggingExporter struct { } func (s *loggingExporter) pushTraces(_ context.Context, td pdata.Traces) error { - s.logger.Info("TracesExporter", zap.Int("#spans", td.SpanCount())) + fields := []zap.Field{ + zap.Int("#spans", td.SpanCount()), + } + + ac := configauth.ExtractPDataContext(td.ResourceSpans().At(0).PDataContext()) + if ac != nil { + fields = append(fields, zap.String("sub", ac.Subject())) + fields = append(fields, zap.Strings("groups", ac.Groups())) + } else { + fields = append(fields, zap.String("auth", "none")) + } + + s.logger.Info("TracesExporter", fields...) if !s.debug { return nil