mirror of
https://github.com/grafana/grafana.git
synced 2024-12-02 13:39:19 -06:00
0a95d493e3
* remove angular code * format annotation on backend * format time with time type instead of string * update annotation query tests * update get alignment data function * update annotation query editor * add annotation query editor test * update struct * add tests * remove extracted function * remove non-null assertion * remove stray commented out console.log * fix jest haste map warning * add alignment period * add AnnotationMetricQuery type
103 lines
2.6 KiB
Go
103 lines
2.6 KiB
Go
package cloudmonitoring
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/grafana/grafana-plugin-sdk-go/backend"
|
|
"github.com/grafana/grafana-plugin-sdk-go/data"
|
|
)
|
|
|
|
type annotationEvent struct {
|
|
Title string
|
|
Time time.Time
|
|
Tags string
|
|
Text string
|
|
}
|
|
|
|
func (s *Service) executeAnnotationQuery(ctx context.Context, req *backend.QueryDataRequest, dsInfo datasourceInfo) (
|
|
*backend.QueryDataResponse, error) {
|
|
resp := backend.NewQueryDataResponse()
|
|
|
|
queries, err := s.buildQueryExecutors(req)
|
|
if err != nil {
|
|
return resp, err
|
|
}
|
|
|
|
queryRes, dr, _, err := queries[0].run(ctx, req, s, dsInfo, s.tracer)
|
|
if err != nil {
|
|
return resp, err
|
|
}
|
|
|
|
mq := struct {
|
|
MetricQuery struct {
|
|
Title string `json:"title"`
|
|
Text string `json:"text"`
|
|
} `json:"metricQuery"`
|
|
}{}
|
|
|
|
firstQuery := req.Queries[0]
|
|
err = json.Unmarshal(firstQuery.JSON, &mq)
|
|
if err != nil {
|
|
return resp, nil
|
|
}
|
|
err = queries[0].parseToAnnotations(queryRes, dr, mq.MetricQuery.Title, mq.MetricQuery.Text)
|
|
resp.Responses[firstQuery.RefID] = *queryRes
|
|
|
|
return resp, err
|
|
}
|
|
|
|
func (timeSeriesQuery cloudMonitoringTimeSeriesQuery) transformAnnotationToFrame(annotations []*annotationEvent, result *backend.DataResponse) {
|
|
frame := data.NewFrame(timeSeriesQuery.RefID,
|
|
data.NewField("time", nil, []time.Time{}),
|
|
data.NewField("title", nil, []string{}),
|
|
data.NewField("tags", nil, []string{}),
|
|
data.NewField("text", nil, []string{}),
|
|
)
|
|
for _, a := range annotations {
|
|
frame.AppendRow(a.Time, a.Title, a.Tags, a.Text)
|
|
}
|
|
result.Frames = append(result.Frames, frame)
|
|
slog.Info("anno", "len", len(annotations))
|
|
}
|
|
|
|
func formatAnnotationText(annotationText string, pointValue string, metricType string, metricLabels map[string]string, resourceLabels map[string]string) string {
|
|
result := legendKeyFormat.ReplaceAllFunc([]byte(annotationText), func(in []byte) []byte {
|
|
metaPartName := strings.Replace(string(in), "{{", "", 1)
|
|
metaPartName = strings.Replace(metaPartName, "}}", "", 1)
|
|
metaPartName = strings.TrimSpace(metaPartName)
|
|
|
|
if metaPartName == "metric.type" {
|
|
return []byte(metricType)
|
|
}
|
|
|
|
metricPart := replaceWithMetricPart(metaPartName, metricType)
|
|
|
|
if metricPart != nil {
|
|
return metricPart
|
|
}
|
|
|
|
if metaPartName == "metric.value" {
|
|
return []byte(pointValue)
|
|
}
|
|
|
|
metaPartName = strings.Replace(metaPartName, "metric.label.", "", 1)
|
|
|
|
if val, exists := metricLabels[metaPartName]; exists {
|
|
return []byte(val)
|
|
}
|
|
|
|
metaPartName = strings.Replace(metaPartName, "resource.label.", "", 1)
|
|
|
|
if val, exists := resourceLabels[metaPartName]; exists {
|
|
return []byte(val)
|
|
}
|
|
|
|
return in
|
|
})
|
|
|
|
return string(result)
|
|
}
|