|
|
package common
|
|
|
|
|
|
import (
|
|
|
"io"
|
|
|
"log"
|
|
|
"time"
|
|
|
|
|
|
"github.com/opentracing/opentracing-go"
|
|
|
"github.com/uber/jaeger-client-go"
|
|
|
"github.com/uber/jaeger-client-go/config"
|
|
|
)
|
|
|
|
|
|
// 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()
|
|
|
// }
|
|
|
|
|
|
const vmwareAddr = "192.168.71.200"
|
|
|
|
|
|
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,
|
|
|
// 方法1: 使用 HTTP Collector 直接发送
|
|
|
CollectorEndpoint: "http://" + vmwareAddr + ":14268/api/traces",
|
|
|
// 注释掉 LocalAgentHostPort，因为我们使用 CollectorEndpoint
|
|
|
// LocalAgentHostPort: addr,
|
|
|
},
|
|
|
}
|
|
|
|
|
|
tracer, closer, err := cfg.NewTracer()
|
|
|
if err != nil {
|
|
|
return nil, nil, err
|
|
|
}
|
|
|
|
|
|
log.Printf("Jaeger tracer 初始化成功 - 服务: %s, 端点: %s", serviceName, "http://192.168.71.172:14268/api/traces")
|
|
|
return tracer, closer, nil
|
|
|
}
|
