Skip to content
This repository has been archived by the owner on Feb 17, 2025. It is now read-only.

Commit

Permalink
feat: disable stdout tracer
Browse files Browse the repository at this point in the history
  • Loading branch information
1995parham committed Sep 18, 2021
1 parent 865ee07 commit d7f1232
Showing 1 changed file with 4 additions and 11 deletions.
15 changes: 4 additions & 11 deletions internal/telemetry/trace/trace.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ import (
"github.com/snapp-incubator/stan-js-replicator/internal/telemetry/config"
"go.opentelemetry.io/otel"
"go.opentelemetry.io/otel/exporters/jaeger"
stdout "go.opentelemetry.io/otel/exporters/stdout/stdouttrace"
"go.opentelemetry.io/otel/propagation"
"go.opentelemetry.io/otel/sdk/resource"
sdktrace "go.opentelemetry.io/otel/sdk/trace"
Expand All @@ -15,19 +14,13 @@ import (
)

func New(cfg config.Trace) trace.Tracer {
var exporter sdktrace.SpanExporter

var err error
if !cfg.Enabled {
exporter, err = stdout.New(
stdout.WithPrettyPrint(),
)
} else {
exporter, err = jaeger.New(
jaeger.WithAgentEndpoint(jaeger.WithAgentHost(cfg.Agent.Host), jaeger.WithAgentPort(cfg.Agent.Port)),
)
return trace.NewNoopTracerProvider().Tracer("snapp/stan-js-replicator")
}

exporter, err := jaeger.New(
jaeger.WithAgentEndpoint(jaeger.WithAgentHost(cfg.Agent.Host), jaeger.WithAgentPort(cfg.Agent.Port)),
)
if err != nil {
log.Fatalf("failed to initialize export pipeline: %v", err)
}
Expand Down

0 comments on commit d7f1232

Please sign in to comment.