Skip to content

Commit

Permalink
remove kind and name fields (handled by default)
Browse files Browse the repository at this point in the history
Signed-off-by: Saumyacodes-40 <[email protected]>
  • Loading branch information
Saumya40-codes committed Dec 27, 2024
1 parent 0090b57 commit adafb33
Showing 1 changed file with 5 additions and 25 deletions.
30 changes: 5 additions & 25 deletions receiver/jaegerreceiver/trace_receiver.go
Original file line number Diff line number Diff line change
Expand Up @@ -249,11 +249,7 @@ func (jr *jReceiver) startAgent(host component.Host) error {
}
jr.agentProcessors = append(jr.agentProcessors, processor)

jr.settings.Logger.Info("Starting UDP server for Binary Thrift",
zap.String("kind", "receiver"),
zap.String("name", "jaegerreceiver"),
zap.String("endpoint", jr.config.AgentBinaryThrift.Endpoint),
)
jr.settings.Logger.Info("Starting UDP server for Binary Thrift", zap.String("endpoint", jr.config.AgentBinaryThrift.Endpoint))
}

if jr.config.AgentCompactThrift.Endpoint != "" {
Expand All @@ -275,11 +271,7 @@ func (jr *jReceiver) startAgent(host component.Host) error {
}
jr.agentProcessors = append(jr.agentProcessors, processor)

jr.settings.Logger.Info("Starting UDP server for Compact Thrift",
zap.String("kind", "receiver"),
zap.String("name", "jaegerreceiver"),
zap.String("endpoint", jr.config.AgentCompactThrift.Endpoint),
)
jr.settings.Logger.Info("Starting UDP server for Compact Thrift", zap.String("endpoint", jr.config.AgentCompactThrift.Endpoint))
}

jr.goroutines.Add(len(jr.agentProcessors))
Expand All @@ -293,11 +285,7 @@ func (jr *jReceiver) startAgent(host component.Host) error {
if jr.config.AgentHTTPEndpoint != "" {
jr.agentServer = httpserver.NewHTTPServer(jr.config.AgentHTTPEndpoint, &notImplementedConfigManager{}, metrics.NullFactory, jr.settings.Logger)

jr.settings.Logger.Info("Starting HTTP server for Jaeger Agent",
zap.String("kind", "receiver"),
zap.String("name", "jaegerreceiver"),
zap.String("endpoint", jr.config.AgentHTTPEndpoint),
)
jr.settings.Logger.Info("Starting HTTP server for Jaeger Agent", zap.String("endpoint", jr.config.AgentHTTPEndpoint))

jr.goroutines.Add(1)
go func() {
Expand Down Expand Up @@ -407,11 +395,7 @@ func (jr *jReceiver) startCollector(ctx context.Context, host component.Host) er
return err
}

jr.settings.Logger.Info("Starting HTTP server for Jaeger Collector",
zap.String("kind", "receiver"),
zap.String("name", "jaegerreceiver"),
zap.String("endpoint", jr.config.HTTPServerConfig.Endpoint),
)
jr.settings.Logger.Info("Starting HTTP server for Jaeger Collector", zap.String("endpoint", jr.config.HTTPServerConfig.Endpoint))

jr.goroutines.Add(1)
go func() {
Expand All @@ -436,11 +420,7 @@ func (jr *jReceiver) startCollector(ctx context.Context, host component.Host) er

api_v2.RegisterCollectorServiceServer(jr.grpc, jr)

jr.settings.Logger.Info("Starting gRPC server for Jaeger Collector",
zap.String("kind", "receiver"),
zap.String("name", "jaegerreceiver"),
zap.String("endpoint", jr.config.GRPCServerConfig.NetAddr.Endpoint),
)
jr.settings.Logger.Info("Starting gRPC server for Jaeger Collector", zap.String("endpoint", jr.config.GRPCServerConfig.NetAddr.Endpoint))

jr.goroutines.Add(1)
go func() {
Expand Down

0 comments on commit adafb33

Please sign in to comment.