tracer
easy tracer api for jaeger
Feature:
support component:
- http middleware
- grpc middleware
- redis hook
- function middleware
- easy api
Usage:
init tracer
func NewTracer(serviceName string, addr string, fns ...optionFunc) (opentracing.Tracer, io.Closer, error) {
start span
func handleLogic(ctx context.Context, params interface{}) error {
span, cctx := tracer.StartSpanFromContext(ctx, tracer.GetFunc())
defer func() {
span.SetTag("request", params)
span.Finish()
}()
resp, err := httpGet(cctx, "http://127.0.0.1:8181/ping", map[string]interface{}{"k1": "v1"})
if err != nil {
return err
}
return nil
}
func httpGet(ctx context.Context, url string, data map[string]interface{}) (*req.Resp, error) {
span, _ := tracer.StartSpanFromContext(ctx, tracer.GetFunc())
defer func() {
span.SetTag("url", url)
span.Finish()
}()
header := make(http.Header, 10)
err := tracer.InjectHttpHeader(span, header)
if err != nil {
span.LogFields(tracer.LogString("inject-error", err.Error()))
}
resp, err := req.Get(url, header)
return resp, err
}
gin middleware
r := gin.Default()
r.Use(tracer.TracingMiddleware(serviceName))
r.GET("/ping", handlePing)
r.Run(bindAddr)
grpc server interceptor
listener, err := net.Listen("tcp", bindAddr)
grpcServer := grpc.NewServer(tracer.GrpcServerOption())
grpcServer.Serve(listener)
For more usage, please see the code !!!
full example
request path:
- client
- gateway
- service
- cache
start jaeger all in one container
bash example/start_jaeger.sh
start servers
- go run example/gateway/gw.go --trace-addr=127.0.0.1:6381
- go run example/service/service.go --trace-addr=127.0.0.1:6381
- go run example/cache/cache.go --trace-addr=127.0.0.1:6381
send request to gateway
Three ways to start the client !!!
- go run example/client/client.go --trace-addr=127.0.0.1:6381
- bash example/curl.sh, http request with custom x-trace-id.
- curl -vvv 127.0.0.1:8080/ping
$ > bash example/curl.sh
x-trace-id ===> 230b497c161e83e9:230b497c161e83e9:0000000000000000:1
* Trying 127.0.0.1:8080...
* Connected to 127.0.0.1 (127.0.0.1) port 8080 (#0)
> GET /ping HTTP/1.1
> Host: 127.0.0.1:8080
> User-Agent: curl/7.71.1
> Accept: */*
> x-trace-id: 230b497c161e83e9:230b497c161e83e9:0000000000000000:1
* Mark bundle as not supporting multiuse
< HTTP/1.1 200 OK
< Content-Type: application/json; charset=utf-8
< Span-Id: 07f59dea1f92f1dd
< Trace-Id: 230b497c161e83e9
< Date: Sun, 06 Feb 2022 01:29:55 GMT
< Content-Length: 18
<
* Connection #0 to host 127.0.0.1 left intact
{"message":"pong"}%
query trace in UI
- open
http://${jaeger_query_addr}:16686/searchin chrome browser. - input trace-id in jaeger ui.
