bingyi/gf
1
0
Fork 0
mirror of https://gitee.com/johng/gf synced 2026-06-06 16:21:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

add tracing feature for ghttp.Client

Browse Source
This commit is contained in:
jianchenma
2021-01-25 14:54:38 +08:00
parent e622ece861
commit 3f2ae3ba62
21 changed files with 963 additions and 892 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
.example/net/gtrace/jaeger/main.go → .example/net/ghttp/client/tracing/jaeger/main.go
View File

@ -20,6 +20,7 @@ import (
"context"
"fmt"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/net/ghttp"
"go.opentelemetry.io/otel/exporters/trace/jaeger"
"go.opentelemetry.io/otel/trace"
"log"
@ -57,16 +58,27 @@ func main() {
flush := initTracer()
defer flush()
ctx, span := otel.Tracer("component-main").Start(ctx, "foo")
ctx, span := otel.Tracer("test").Start(ctx, "test")
defer span.End()
content := g.Client().Ctx(ctx).Header(g.MapStrStr{
"test": "123",
"john": "smith",
}).Cookie(g.MapStrStr{
"cookieKey":"cookieValue",
}).GetContent("http://baidu.com/?q=goframe")
fmt.Println(content)
for i := 0; i < 20; i++ {
g.Client().Use(ghttp.MiddlewareClientTracing).Ctx(ctx).Header(g.MapStrStr{
"test": "123",
"john": "smith",
}).Cookie(g.MapStrStr{
"cookieKey": "cookieValue",
}).GetContent(fmt.Sprintf("http://baidu.com/?q=test_%d", i))
}
foo(ctx)
}
func foo(ctx context.Context) {
ctx, span := otel.Tracer("test").Start(ctx, "foo")
defer span.End()
span.AddEvent("Nice operation!", trace.WithAttributes(label.Int("bogons", 100)))
span.SetAttributes(label.String("test2", "123"))
time.Sleep(time.Second * 1)
bar(ctx)
}
func bar(ctx context.Context) {
@ -74,6 +86,6 @@ func bar(ctx context.Context) {
defer span.End()
span.AddEvent("Nice operation!", trace.WithAttributes(label.Int("bogons", 100)))
span.SetAttributes(label.String("test2", "123"))
time.Sleep(time.Second * 2)
time.Sleep(time.Second * 1)
// Do bar...
}