forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-21 12:16:44 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

rpc: use global OpenTelemetry tracer provider by default.

Browse source
This commit is contained in:
jonny rhea 2025-12-23 14:06:16 -06:00
parent 8254381bfd
commit 479a2f8804
2 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
rpc/client.go
View file

@ -29,8 +29,8 @@ import (
"time"
"github.com/ethereum/go-ethereum/log"
"go.opentelemetry.io/otel"
"go.opentelemetry.io/otel/trace"
"go.opentelemetry.io/otel/trace/noop"
)
var (
@ -268,7 +268,7 @@ func initClient(conn ServerCodec, services *serviceRegistry, cfg *clientConfig)
c.idgen = randomIDGenerator()
}
if c.tracer == nil {
c.tracer = noop.NewTracerProvider().Tracer(tracerName)
c.tracer = otel.GetTracerProvider().Tracer(tracerName)
}
// Launch the main loop.

7
rpc/server.go
View file

@ -24,8 +24,8 @@ import (
"sync"
"sync/atomic"
"go.opentelemetry.io/otel"
"go.opentelemetry.io/otel/trace"
"go.opentelemetry.io/otel/trace/noop"
"github.com/ethereum/go-ethereum/log"
)
@ -69,7 +69,7 @@ func NewServer() *Server {
codecs: make(map[ServerCodec]struct{}),
httpBodyLimit: defaultBodyLimit,
wsReadLimit: wsDefaultReadLimit,
tracer: noop.NewTracerProvider().Tracer(tracerName),
tracer: otel.GetTracerProvider().Tracer(tracerName),
}
server.run.Store(true)
// Register the default service providing meta information about the RPC service such
@ -107,7 +107,8 @@ func (s *Server) SetWebsocketReadLimit(limit int64) {
// SetTracerProvider configures the OpenTelemetry TracerProvider for RPC call tracing.
func (s *Server) SetTracerProvider(tp trace.TracerProvider) {
if tp == nil {
s.tracer = noop.NewTracerProvider().Tracer(tracerName)
// Reset to the global provider (which is noop unless configured elsewhere).
s.tracer = otel.GetTracerProvider().Tracer(tracerName)
return
}
s.tracer = tp.Tracer(tracerName)