From c48caf09210d59d883abf11d066234a3021986b7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?G=C3=A1bor=20Farkas?= Date: Tue, 10 Sep 2024 13:25:50 +0200 Subject: [PATCH] logging: log plugin request start (#92925) log plugin request start --- .../clientmiddleware/logger_middleware.go | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) diff --git a/pkg/services/pluginsintegration/clientmiddleware/logger_middleware.go b/pkg/services/pluginsintegration/clientmiddleware/logger_middleware.go index 409621f133a..526c13b95fa 100644 --- a/pkg/services/pluginsintegration/clientmiddleware/logger_middleware.go +++ b/pkg/services/pluginsintegration/clientmiddleware/logger_middleware.go @@ -46,21 +46,26 @@ func (m *LoggerMiddleware) logRequest(ctx context.Context, pCtx backend.PluginCo start := time.Now() timeBeforePluginRequest := log.TimeSinceStart(ctx, start) - status, err := fn(ctx) + ctxLogger := m.logger.FromContext(ctx) + logFunc := ctxLogger.Info + logParams := []any{ - "status", status.String(), - "duration", time.Since(start), "eventName", "grafana-data-egress", "time_before_plugin_request", timeBeforePluginRequest, "target", m.pluginTarget(ctx, pCtx), } + + logFunc("Plugin Request Started", logParams...) + + status, err := fn(ctx) + + logParams = append(logParams, "status", status.String(), "duration", time.Since(start)) + if err != nil { logParams = append(logParams, "error", err) } logParams = append(logParams, "statusSource", pluginrequestmeta.StatusSourceFromContext(ctx)) - ctxLogger := m.logger.FromContext(ctx) - logFunc := ctxLogger.Info if status > instrumentationutils.RequestStatusOK { logFunc = ctxLogger.Error }