[chore] jaeger receiver ReportFatalError -> ReportStatus (open-teleme…

…try#30609) Remove use of deprecated host.ReportFatalError Linked to open-telemetry#30501 Fixes open-telemetry#30591 Signed-off-by: Alex Boten <aboten@lightstep.com>
AmadeusITGroup · Feb 1, 2024 · 9637a30 · 9637a30
1 parent 2938f8a
commit 9637a30
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/receiver/jaegerreceiver/jaeger_agent_test.go b/receiver/jaegerreceiver/jaeger_agent_test.go
@@ -85,7 +85,7 @@ func TestJaegerAgentUDP_ThriftBinary_PortInUse(t *testing.T) {
 	jr, err := newJaegerReceiver(jaegerAgent, config, nil, set)
 	require.NoError(t, err)
 
-	assert.NoError(t, jr.startAgent(componenttest.NewNopHost()), "Start failed")
+	assert.NoError(t, jr.startAgent(), "Start failed")
 	t.Cleanup(func() { require.NoError(t, jr.Shutdown(context.Background())) })
 
 	l, err := net.Listen("udp", addr)

diff --git a/receiver/jaegerreceiver/trace_receiver.go b/receiver/jaegerreceiver/trace_receiver.go
@@ -125,7 +125,7 @@ func newJaegerReceiver(
 }
 
 func (jr *jReceiver) Start(_ context.Context, host component.Host) error {
-	if err := jr.startAgent(host); err != nil {
+	if err := jr.startAgent(); err != nil {
 		return err
 	}
 
@@ -222,7 +222,7 @@ func (jr *jReceiver) PostSpans(ctx context.Context, r *api_v2.PostSpansRequest)
 	return &api_v2.PostSpansResponse{}, nil
 }
 
-func (jr *jReceiver) startAgent(host component.Host) error {
+func (jr *jReceiver) startAgent() error {
 	if jr.config == nil {
 		return nil
 	}
@@ -283,7 +283,7 @@ func (jr *jReceiver) startAgent(host component.Host) error {
 		go func() {
 			defer jr.goroutines.Done()
 			if err := jr.agentServer.ListenAndServe(); !errors.Is(err, http.ErrServerClosed) && err != nil {
-				host.ReportFatalError(fmt.Errorf("jaeger agent server error: %w", err))
+				jr.settings.ReportStatus(component.NewFatalErrorEvent(fmt.Errorf("jaeger agent server error: %w", err)))
 			}
 		}()
 	}
@@ -391,7 +391,7 @@ func (jr *jReceiver) startCollector(host component.Host) error {
 		go func() {
 			defer jr.goroutines.Done()
 			if errHTTP := jr.collectorServer.Serve(cln); !errors.Is(errHTTP, http.ErrServerClosed) && errHTTP != nil {
-				host.ReportFatalError(errHTTP)
+				jr.settings.ReportStatus(component.NewFatalErrorEvent(errHTTP))
 			}
 		}()
 	}
@@ -414,7 +414,7 @@ func (jr *jReceiver) startCollector(host component.Host) error {
 		go func() {
 			defer jr.goroutines.Done()
 			if errGrpc := jr.grpc.Serve(ln); !errors.Is(errGrpc, grpc.ErrServerStopped) && errGrpc != nil {
-				host.ReportFatalError(errGrpc)
+				jr.settings.ReportStatus(component.NewFatalErrorEvent(errGrpc))
 			}
 		}()
 	}