mirror of
https://github.com/grafana/grafana.git
synced 2025-01-17 12:03:26 -06:00
0cb29d337a
* comes from grafana/gel-app * remove transform plugin code * move __expr__ and -100 constants to expr pkg * set OrgID on request plugin context * use gtime for resample duration * in resample, rename "rule" to "window", use gtime for duration, parse duration before exec * remove gel entry from plugins-bundled/external.json which creates an empty array for plugins
83 lines
2.5 KiB
Go
83 lines
2.5 KiB
Go
package backendplugin
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
"github.com/grafana/grafana-plugin-sdk-go/backend"
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
)
|
|
|
|
var (
|
|
pluginRequestCounter *prometheus.CounterVec
|
|
pluginRequestDuration *prometheus.SummaryVec
|
|
)
|
|
|
|
func init() {
|
|
pluginRequestCounter = prometheus.NewCounterVec(prometheus.CounterOpts{
|
|
Namespace: "grafana",
|
|
Name: "plugin_request_total",
|
|
Help: "The total amount of plugin requests",
|
|
}, []string{"plugin_id", "endpoint", "status"})
|
|
|
|
pluginRequestDuration = prometheus.NewSummaryVec(prometheus.SummaryOpts{
|
|
Namespace: "grafana",
|
|
Name: "plugin_request_duration_milliseconds",
|
|
Help: "Plugin request duration",
|
|
Objectives: map[float64]float64{0.5: 0.05, 0.9: 0.01, 0.99: 0.001},
|
|
}, []string{"plugin_id", "endpoint"})
|
|
|
|
prometheus.MustRegister(pluginRequestCounter, pluginRequestDuration)
|
|
}
|
|
|
|
// instrumentPluginRequest instruments success rate and latency of `fn`
|
|
func instrumentPluginRequest(pluginID string, endpoint string, fn func() error) error {
|
|
status := "ok"
|
|
|
|
start := time.Now()
|
|
|
|
err := fn()
|
|
if err != nil {
|
|
status = "error"
|
|
}
|
|
|
|
elapsed := time.Since(start) / time.Millisecond
|
|
pluginRequestDuration.WithLabelValues(pluginID, endpoint).Observe(float64(elapsed))
|
|
pluginRequestCounter.WithLabelValues(pluginID, endpoint, status).Inc()
|
|
|
|
return err
|
|
}
|
|
|
|
func instrumentCollectMetrics(pluginID string, fn func() error) error {
|
|
return instrumentPluginRequest(pluginID, "collectMetrics", fn)
|
|
}
|
|
|
|
func instrumentCheckHealthRequest(pluginID string, fn func() error) error {
|
|
return instrumentPluginRequest(pluginID, "checkHealth", fn)
|
|
}
|
|
|
|
func instrumentCallResourceRequest(pluginID string, fn func() error) error {
|
|
return instrumentPluginRequest(pluginID, "callResource", fn)
|
|
}
|
|
|
|
// InstrumentQueryDataRequest instruments success rate and latency of query data request.
|
|
func InstrumentQueryDataRequest(pluginID string, fn func() error) error {
|
|
return instrumentPluginRequest(pluginID, "queryData", fn)
|
|
}
|
|
|
|
// InstrumentQueryDataHandler wraps a backend.QueryDataHandler with instrumentation of success rate and latency.
|
|
func InstrumentQueryDataHandler(handler backend.QueryDataHandler) backend.QueryDataHandler {
|
|
if handler == nil {
|
|
return nil
|
|
}
|
|
|
|
return backend.QueryDataHandlerFunc(func(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error) {
|
|
var resp *backend.QueryDataResponse
|
|
err := InstrumentQueryDataRequest(req.PluginContext.PluginID, func() (innerErr error) {
|
|
resp, innerErr = handler.QueryData(ctx, req)
|
|
return
|
|
})
|
|
return resp, err
|
|
})
|
|
}
|