jkurik / rpms / grafana

Forked from rpms/grafana 3 years ago
Clone

Blame 002-remove-jaeger-tracing.patch

1f64cbe
diff --git a/pkg/cmd/grafana-server/server.go b/pkg/cmd/grafana-server/server.go
5c9d1ea
index 2ac326ed3..20943918c 100644
1f64cbe
--- a/pkg/cmd/grafana-server/server.go
1f64cbe
+++ b/pkg/cmd/grafana-server/server.go
5c9d1ea
@@ -21,7 +21,6 @@ import (
1f64cbe
 	_ "github.com/grafana/grafana/pkg/infra/metrics"
1f64cbe
 	_ "github.com/grafana/grafana/pkg/infra/remotecache"
1f64cbe
 	_ "github.com/grafana/grafana/pkg/infra/serverlock"
1f64cbe
-	_ "github.com/grafana/grafana/pkg/infra/tracing"
1f64cbe
 	_ "github.com/grafana/grafana/pkg/infra/usagestats"
5c9d1ea
 	"github.com/grafana/grafana/pkg/log"
5c9d1ea
 	"github.com/grafana/grafana/pkg/login"
1f64cbe
diff --git a/pkg/infra/tracing/tracing.go b/pkg/infra/tracing/tracing.go
1f64cbe
deleted file mode 100644
1f64cbe
index fd7258b7a..000000000
1f64cbe
--- a/pkg/infra/tracing/tracing.go
1f64cbe
+++ /dev/null
1f64cbe
@@ -1,129 +0,0 @@
1f64cbe
-package tracing
1f64cbe
-
1f64cbe
-import (
1f64cbe
-	"context"
1f64cbe
-	"io"
1f64cbe
-	"strings"
1f64cbe
-
1f64cbe
-	"github.com/grafana/grafana/pkg/log"
1f64cbe
-	"github.com/grafana/grafana/pkg/registry"
1f64cbe
-	"github.com/grafana/grafana/pkg/setting"
1f64cbe
-
1f64cbe
-	opentracing "github.com/opentracing/opentracing-go"
1f64cbe
-	jaegercfg "github.com/uber/jaeger-client-go/config"
1f64cbe
-)
1f64cbe
-
1f64cbe
-func init() {
1f64cbe
-	registry.RegisterService(&TracingService{})
1f64cbe
-}
1f64cbe
-
1f64cbe
-type TracingService struct {
1f64cbe
-	enabled      bool
1f64cbe
-	address      string
1f64cbe
-	customTags   map[string]string
1f64cbe
-	samplerType  string
1f64cbe
-	samplerParam float64
1f64cbe
-	log          log.Logger
1f64cbe
-	closer       io.Closer
1f64cbe
-
1f64cbe
-	Cfg *setting.Cfg `inject:""`
1f64cbe
-}
1f64cbe
-
1f64cbe
-func (ts *TracingService) Init() error {
1f64cbe
-	ts.log = log.New("tracing")
1f64cbe
-	ts.parseSettings()
1f64cbe
-
1f64cbe
-	if ts.enabled {
1f64cbe
-		ts.initGlobalTracer()
1f64cbe
-	}
1f64cbe
-
1f64cbe
-	return nil
1f64cbe
-}
1f64cbe
-
1f64cbe
-func (ts *TracingService) parseSettings() {
1f64cbe
-	var section, err = ts.Cfg.Raw.GetSection("tracing.jaeger")
1f64cbe
-	if err != nil {
1f64cbe
-		return
1f64cbe
-	}
1f64cbe
-
1f64cbe
-	ts.address = section.Key("address").MustString("")
1f64cbe
-	if ts.address != "" {
1f64cbe
-		ts.enabled = true
1f64cbe
-	}
1f64cbe
-
1f64cbe
-	ts.customTags = splitTagSettings(section.Key("always_included_tag").MustString(""))
1f64cbe
-	ts.samplerType = section.Key("sampler_type").MustString("")
1f64cbe
-	ts.samplerParam = section.Key("sampler_param").MustFloat64(1)
1f64cbe
-}
1f64cbe
-
1f64cbe
-func (ts *TracingService) initGlobalTracer() error {
1f64cbe
-	cfg := jaegercfg.Configuration{
1f64cbe
-		ServiceName: "grafana",
1f64cbe
-		Disabled:    !ts.enabled,
1f64cbe
-		Sampler: &jaegercfg.SamplerConfig{
1f64cbe
-			Type:  ts.samplerType,
1f64cbe
-			Param: ts.samplerParam,
1f64cbe
-		},
1f64cbe
-		Reporter: &jaegercfg.ReporterConfig{
1f64cbe
-			LogSpans:           false,
1f64cbe
-			LocalAgentHostPort: ts.address,
1f64cbe
-		},
1f64cbe
-	}
1f64cbe
-
1f64cbe
-	jLogger := &jaegerLogWrapper{logger: log.New("jaeger")}
1f64cbe
-
1f64cbe
-	options := []jaegercfg.Option{}
1f64cbe
-	options = append(options, jaegercfg.Logger(jLogger))
1f64cbe
-
1f64cbe
-	for tag, value := range ts.customTags {
1f64cbe
-		options = append(options, jaegercfg.Tag(tag, value))
1f64cbe
-	}
1f64cbe
-
1f64cbe
-	tracer, closer, err := cfg.NewTracer(options...)
1f64cbe
-	if err != nil {
1f64cbe
-		return err
1f64cbe
-	}
1f64cbe
-
1f64cbe
-	opentracing.InitGlobalTracer(tracer)
1f64cbe
-
1f64cbe
-	ts.closer = closer
1f64cbe
-
1f64cbe
-	return nil
1f64cbe
-}
1f64cbe
-
1f64cbe
-func (ts *TracingService) Run(ctx context.Context) error {
1f64cbe
-	<-ctx.Done()
1f64cbe
-
1f64cbe
-	if ts.closer != nil {
1f64cbe
-		ts.log.Info("Closing tracing")
1f64cbe
-		ts.closer.Close()
1f64cbe
-	}
1f64cbe
-
1f64cbe
-	return nil
1f64cbe
-}
1f64cbe
-
1f64cbe
-func splitTagSettings(input string) map[string]string {
1f64cbe
-	res := map[string]string{}
1f64cbe
-
1f64cbe
-	tags := strings.Split(input, ",")
1f64cbe
-	for _, v := range tags {
1f64cbe
-		kv := strings.Split(v, ":")
1f64cbe
-		if len(kv) > 1 {
1f64cbe
-			res[kv[0]] = kv[1]
1f64cbe
-		}
1f64cbe
-	}
1f64cbe
-
1f64cbe
-	return res
1f64cbe
-}
1f64cbe
-
1f64cbe
-type jaegerLogWrapper struct {
1f64cbe
-	logger log.Logger
1f64cbe
-}
1f64cbe
-
1f64cbe
-func (jlw *jaegerLogWrapper) Error(msg string) {
1f64cbe
-	jlw.logger.Error(msg)
1f64cbe
-}
1f64cbe
-
1f64cbe
-func (jlw *jaegerLogWrapper) Infof(msg string, args ...interface{}) {
1f64cbe
-	jlw.logger.Info(msg, args)
1f64cbe
-}
1f64cbe
diff --git a/pkg/infra/tracing/tracing_test.go b/pkg/infra/tracing/tracing_test.go
1f64cbe
deleted file mode 100644
1f64cbe
index 27e4de777..000000000
1f64cbe
--- a/pkg/infra/tracing/tracing_test.go
1f64cbe
+++ /dev/null
1f64cbe
@@ -1,36 +0,0 @@
1f64cbe
-package tracing
1f64cbe
-
1f64cbe
-import "testing"
1f64cbe
-
1f64cbe
-func TestGroupSplit(t *testing.T) {
1f64cbe
-	tests := []struct {
1f64cbe
-		input    string
1f64cbe
-		expected map[string]string
1f64cbe
-	}{
1f64cbe
-		{
1f64cbe
-			input: "tag1:value1,tag2:value2",
1f64cbe
-			expected: map[string]string{
1f64cbe
-				"tag1": "value1",
1f64cbe
-				"tag2": "value2",
1f64cbe
-			},
1f64cbe
-		},
1f64cbe
-		{
1f64cbe
-			input:    "",
1f64cbe
-			expected: map[string]string{},
1f64cbe
-		},
1f64cbe
-		{
1f64cbe
-			input:    "tag1",
1f64cbe
-			expected: map[string]string{},
1f64cbe
-		},
1f64cbe
-	}
1f64cbe
-
1f64cbe
-	for _, test := range tests {
1f64cbe
-		tags := splitTagSettings(test.input)
1f64cbe
-		for k, v := range test.expected {
1f64cbe
-			value, exists := tags[k]
1f64cbe
-			if !exists || value != v {
1f64cbe
-				t.Errorf("tags does not match %v ", test)
1f64cbe
-			}
1f64cbe
-		}
1f64cbe
-	}
1f64cbe
-}