You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
30 lines
632 B
30 lines
632 B
2 years ago
|
package common
|
||
|
|
|
||
|
|
import (
|
||
|
|
"github.com/opentracing/opentracing-go"
|
||
|
|
jaeger "github.com/uber/jaeger-client-go"
|
||
|
|
"github.com/uber/jaeger-client-go/config"
|
||
|
|
"io"
|
||
|
|
"time"
|
||
|
|
)
|
||
|
|
|
||
|
|
/*
|
||
|
|
@Auth:ShenZ
|
||
|
|
@Description: Jaeger的实列化方法
|
||
|
|
*/
|
||
|
|
func NewTracer(serviceName string, addr string) (opentracing.Tracer, io.Closer, error) {
|
||
|
|
cfg := &config.Configuration{
|
||
|
|
ServiceName: serviceName,
|
||
|
|
Sampler: &config.SamplerConfig{
|
||
|
|
Type: jaeger.SamplerTypeConst,
|
||
|
|
Param: 1,
|
||
|
|
},
|
||
|
|
Reporter: &config.ReporterConfig{
|
||
|
|
BufferFlushInterval: 1 * time.Second,
|
||
|
|
LogSpans: true,
|
||
|
|
LocalAgentHostPort: addr,
|
||
|
|
},
|
||
|
|
}
|
||
|
|
return cfg.NewTracer()
|
||
|
|
}
|