opensource/grafana
1
0
Fork 0
mirror of https://github.com/grafana/grafana.git synced 2025-08-02 11:13:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

Plugins: Add status_source label to plugin request logs (#76676)

Browse Source
This commit is contained in:
Giuseppe Guerra
2023-10-17 11:09:01 +02:00
committed by GitHub
parent e1838f92cf
commit c4fefd8da9
2 changed files with 13 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/services/pluginsintegration/clientmiddleware/logger_middleware.go
View File

@ -10,27 +10,31 @@ import (
"github.com/grafana/grafana/pkg/infra/log"
"github.com/grafana/grafana/pkg/plugins"
plog "github.com/grafana/grafana/pkg/plugins/log"
"github.com/grafana/grafana/pkg/plugins/pluginrequestmeta"
"github.com/grafana/grafana/pkg/services/featuremgmt"
"github.com/grafana/grafana/pkg/setting"
)
// NewLoggerMiddleware creates a new plugins.ClientMiddleware that will
// log requests.
func NewLoggerMiddleware(cfg *setting.Cfg, logger plog.Logger) plugins.ClientMiddleware {
func NewLoggerMiddleware(cfg *setting.Cfg, logger plog.Logger, features featuremgmt.FeatureToggles) plugins.ClientMiddleware {
return plugins.ClientMiddlewareFunc(func(next plugins.Client) plugins.Client {
if !cfg.PluginLogBackendRequests {
return next
}
return &LoggerMiddleware{
next: next,
logger: logger,
next: next,
logger: logger,
features: features,
}
})
}
type LoggerMiddleware struct {
next plugins.Client
logger plog.Logger
next plugins.Client
logger plog.Logger
features featuremgmt.FeatureToggles
}
func (m *LoggerMiddleware) logRequest(ctx context.Context, fn func(ctx context.Context) error) error {
@ -45,7 +49,6 @@ func (m *LoggerMiddleware) logRequest(ctx context.Context, fn func(ctx context.C
status = statusCancelled
}
}
logParams := []any{
"status", status,
"duration", time.Since(start),
@ -55,6 +58,9 @@ func (m *LoggerMiddleware) logRequest(ctx context.Context, fn func(ctx context.C
if status == statusError {
logParams = append(logParams, "error", err)
}
if m.features.IsEnabled(featuremgmt.FlagPluginsInstrumentationStatusSource) {
logParams = append(logParams, "status_source", pluginrequestmeta.StatusSourceFromContext(ctx))
}
m.logger.FromContext(ctx).Info("Plugin Request Completed", logParams...)
return err
}