@@ -35,6 +35,7 @@ import (
35
35
"go.opentelemetry.io/collector/receiver"
36
36
"go.opentelemetry.io/collector/receiver/receiverhelper"
37
37
"go.uber.org/multierr"
38
+ "go.uber.org/zap"
38
39
"google.golang.org/grpc"
39
40
40
41
jaegertranslator "github.com/open-telemetry/opentelemetry-collector-contrib/pkg/translator/jaeger"
@@ -247,6 +248,12 @@ func (jr *jReceiver) startAgent(host component.Host) error {
247
248
return err
248
249
}
249
250
jr .agentProcessors = append (jr .agentProcessors , processor )
251
+
252
+ jr .settings .Logger .Info ("Starting Binary Thrift server" ,
253
+ zap .String ("kind" , "receiver" ),
254
+ zap .String ("name" , "jaegerreceiver" ),
255
+ zap .String ("endpoint" , jr .config .AgentBinaryThrift .Endpoint ),
256
+ )
250
257
}
251
258
252
259
if jr .config .AgentCompactThrift .Endpoint != "" {
@@ -267,6 +274,12 @@ func (jr *jReceiver) startAgent(host component.Host) error {
267
274
return err
268
275
}
269
276
jr .agentProcessors = append (jr .agentProcessors , processor )
277
+
278
+ jr .settings .Logger .Info ("Starting Compact Thrift server" ,
279
+ zap .String ("kind" , "receiver" ),
280
+ zap .String ("name" , "jaegerreceiver" ),
281
+ zap .String ("endpoint" , jr .config .AgentCompactThrift .Endpoint ),
282
+ )
270
283
}
271
284
272
285
jr .goroutines .Add (len (jr .agentProcessors ))
@@ -280,6 +293,12 @@ func (jr *jReceiver) startAgent(host component.Host) error {
280
293
if jr .config .AgentHTTPEndpoint != "" {
281
294
jr .agentServer = httpserver .NewHTTPServer (jr .config .AgentHTTPEndpoint , & notImplementedConfigManager {}, metrics .NullFactory , jr .settings .Logger )
282
295
296
+ jr .settings .Logger .Info ("Starting HTTP server" ,
297
+ zap .String ("kind" , "receiver" ),
298
+ zap .String ("name" , "jaegerreceiver" ),
299
+ zap .String ("endpoint" , jr .config .AgentHTTPEndpoint ),
300
+ )
301
+
283
302
jr .goroutines .Add (1 )
284
303
go func () {
285
304
defer jr .goroutines .Done ()
@@ -388,6 +407,12 @@ func (jr *jReceiver) startCollector(ctx context.Context, host component.Host) er
388
407
return err
389
408
}
390
409
410
+ jr .settings .Logger .Info ("Starting HTTP collector server" ,
411
+ zap .String ("kind" , "receiver" ),
412
+ zap .String ("name" , "jaegerreceiver" ),
413
+ zap .String ("endpoint" , jr .config .HTTPServerConfig .Endpoint ),
414
+ )
415
+
391
416
jr .goroutines .Add (1 )
392
417
go func () {
393
418
defer jr .goroutines .Done ()
@@ -411,6 +436,12 @@ func (jr *jReceiver) startCollector(ctx context.Context, host component.Host) er
411
436
412
437
api_v2 .RegisterCollectorServiceServer (jr .grpc , jr )
413
438
439
+ jr .settings .Logger .Info ("Starting gRPC collector server" ,
440
+ zap .String ("kind" , "receiver" ),
441
+ zap .String ("name" , "jaegerreceiver" ),
442
+ zap .String ("endpoint" , jr .config .GRPCServerConfig .NetAddr .Endpoint ),
443
+ )
444
+
414
445
jr .goroutines .Add (1 )
415
446
go func () {
416
447
defer jr .goroutines .Done ()
0 commit comments