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"
@@ -81,17 +79,17 @@ func (c *Server) Execute(args []string) error {
81
79
82
80
var tracer opentracing.Tracer
83
81
if c .TraceEnabled {
84
- if os .Getenv ("JAEGER_SERVICE_NAME" ) == "" {
85
- os .Setenv ("JAEGER_SERVICE_NAME" , TracerServiceName )
86
- }
87
-
88
82
cfg , err := config .FromEnv ()
89
83
if err != nil {
90
84
logrus .WithField ("error" , err ).
91
85
Fatal ("unable to read jaeger environment" )
92
86
return err
93
87
}
94
88
89
+ if cfg .ServiceName == "" {
90
+ cfg .ServiceName = TracerServiceName
91
+ }
92
+
95
93
logger := & jaegerLogrus {logrus .WithField ("subsystem" , "jaeger" )}
96
94
97
95
t , closer , err := cfg .NewTracer (
@@ -106,18 +104,7 @@ func (c *Server) Execute(args []string) error {
106
104
tracer = t
107
105
defer closer .Close ()
108
106
109
- jaegerHost := os .Getenv ("JAEGER_AGENT_HOST" )
110
- if jaegerHost == "" {
111
- jaegerHost = jaeger .DefaultUDPSpanServerHost
112
- }
113
-
114
- jaegerPort := os .Getenv ("JAEGER_AGENT_PORT" )
115
- if jaegerPort == "" {
116
- jaegerPort = strconv .Itoa (jaeger .DefaultUDPSpanServerPort )
117
- }
118
-
119
- endpoint := fmt .Sprintf ("%s:%s" , jaegerHost , jaegerPort )
120
- logrus .WithField ("endpoint" , endpoint ).Info ("tracing enabled" )
107
+ logrus .Info ("tracing enabled" )
121
108
}
122
109
123
110
hostString := net .JoinHostPort (c .Host , strconv .Itoa (c .Port ))
0 commit comments