Skip to content

Commit 3d89398

Browse files
committed
mod: remove datadog tracing
1 parent c17b0be commit 3d89398

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

internal/middleware/plugins/http_proxy.go

+3-4
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@ import (
1212
"github.com/failsafe-go/failsafe-go/circuitbreaker"
1313
cmap "github.com/orcaman/concurrent-map/v2"
1414
"github.com/valyala/fasthttp"
15-
"gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer"
1615

1716
"aggregator/internal/aggregator"
1817
"aggregator/internal/client"
@@ -79,9 +78,9 @@ func (m *HttpProxyMiddleware) OnProcess(session *rpc.Session) error {
7978
if ctx, ok := session.RequestCtx.(*fasthttp.RequestCtx); ok {
8079
startTime := time.Now()
8180
// create a span for a web request at the /{chain} URL
82-
span := tracer.StartSpan("web.request", tracer.ResourceName("/"+session.Chain))
81+
//span := tracer.StartSpan("web.request", tracer.ResourceName("/"+session.Chain))
8382
defer func() {
84-
span.Finish()
83+
//span.Finish()
8584
log.Info(utils.TimeTrack(startTime, session.NodeName))
8685
}()
8786

@@ -137,7 +136,7 @@ func (m *HttpProxyMiddleware) OnProcess(session *rpc.Session) error {
137136
ctx.Request.Header.Set("User-Agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/129.0.0.0 Safari/537.36")
138137

139138
// set tag
140-
span.SetTag("node", session.NodeName)
139+
//span.SetTag("node", session.NodeName)
141140

142141
ctx.Request.SetHost(string(ctx.Host()))
143142
err := failsafe.Run(func() error {

internal/server/server.go

+3-2
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@ import (
88
mfasthttp "github.com/ulule/limiter/v3/drivers/middleware/fasthttp"
99
sredis "github.com/ulule/limiter/v3/drivers/store/redis"
1010
"github.com/valyala/fasthttp"
11-
fasthttptrace "gopkg.in/DataDog/dd-trace-go.v1/contrib/valyala/fasthttp.v1"
1211

1312
"aggregator/internal/config"
1413
"aggregator/internal/env"
@@ -127,7 +126,9 @@ func NewServer() error {
127126
handler = RateLimitMiddleware(rateLimiter, handler)
128127
}
129128
s := &fasthttp.Server{
130-
Handler: fasthttptrace.WrapHandler(handler),
129+
// wrap handler with datadog trace
130+
//Handler: fasthttptrace.WrapHandler(handler),
131+
Handler: handler,
131132
MaxRequestBodySize: fasthttp.DefaultMaxRequestBodySize * 10,
132133
}
133134

0 commit comments

Comments
 (0)