1
1
package command
2
2
3
3
import (
4
- "fmt"
5
4
"net"
6
5
"os"
7
6
"path/filepath"
@@ -14,7 +13,6 @@ import (
14
13
"github.com/opentracing/opentracing-go"
15
14
gopilosa "github.com/pilosa/go-pilosa"
16
15
"github.com/sirupsen/logrus"
17
- jaeger "github.com/uber/jaeger-client-go"
18
16
"github.com/uber/jaeger-client-go/config"
19
17
sqle "gopkg.in/src-d/go-mysql-server.v0"
20
18
"gopkg.in/src-d/go-mysql-server.v0/server"
@@ -82,17 +80,17 @@ func (c *Server) Execute(args []string) error {
82
80
83
81
var tracer opentracing.Tracer
84
82
if c .TraceEnabled {
85
- if os .Getenv ("JAEGER_SERVICE_NAME" ) == "" {
86
- os .Setenv ("JAEGER_SERVICE_NAME" , TracerServiceName )
87
- }
88
-
89
83
cfg , err := config .FromEnv ()
90
84
if err != nil {
91
85
logrus .WithField ("error" , err ).
92
86
Fatal ("unable to read jaeger environment" )
93
87
return err
94
88
}
95
89
90
+ if cfg .ServiceName == "" {
91
+ cfg .ServiceName = TracerServiceName
92
+ }
93
+
96
94
logger := & jaegerLogrus {logrus .WithField ("subsystem" , "jaeger" )}
97
95
98
96
t , closer , err := cfg .NewTracer (
@@ -107,18 +105,7 @@ func (c *Server) Execute(args []string) error {
107
105
tracer = t
108
106
defer closer .Close ()
109
107
110
- jaegerHost := os .Getenv ("JAEGER_AGENT_HOST" )
111
- if jaegerHost == "" {
112
- jaegerHost = jaeger .DefaultUDPSpanServerHost
113
- }
114
-
115
- jaegerPort := os .Getenv ("JAEGER_AGENT_PORT" )
116
- if jaegerPort == "" {
117
- jaegerPort = strconv .Itoa (jaeger .DefaultUDPSpanServerPort )
118
- }
119
-
120
- endpoint := fmt .Sprintf ("%s:%s" , jaegerHost , jaegerPort )
121
- logrus .WithField ("endpoint" , endpoint ).Info ("tracing enabled" )
108
+ logrus .Info ("tracing enabled" )
122
109
}
123
110
124
111
hostString := net .JoinHostPort (c .Host , strconv .Itoa (c .Port ))
0 commit comments