Skip to content

Commit a3a5ea8

Browse files
author
Alex Boten
authored
[chore] loki receiver ReportFatalError -> ReportStatus (#30611)
Remove use of deprecated host.ReportFatalError Linked to #30501 Fixes #30580 Signed-off-by: Alex Boten <[email protected]>
1 parent e5b8f44 commit a3a5ea8

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

receiver/lokireceiver/loki.go

+6-6
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ func (r *lokiReceiver) startProtocolsServers(host component.Host) error {
9999
if err != nil {
100100
return fmt.Errorf("failed create http server error: %w", err)
101101
}
102-
err = r.startHTTPServer(host)
102+
err = r.startHTTPServer()
103103
if err != nil {
104104
return fmt.Errorf("failed to start http server error: %w", err)
105105
}
@@ -113,7 +113,7 @@ func (r *lokiReceiver) startProtocolsServers(host component.Host) error {
113113

114114
push.RegisterPusherServer(r.serverGRPC, r)
115115

116-
err = r.startGRPCServer(host)
116+
err = r.startGRPCServer()
117117
if err != nil {
118118
return fmt.Errorf("failed to start grpc server error: %w", err)
119119
}
@@ -122,7 +122,7 @@ func (r *lokiReceiver) startProtocolsServers(host component.Host) error {
122122
return err
123123
}
124124

125-
func (r *lokiReceiver) startHTTPServer(host component.Host) error {
125+
func (r *lokiReceiver) startHTTPServer() error {
126126
r.settings.Logger.Info("Starting HTTP server", zap.String("endpoint", r.conf.HTTP.Endpoint))
127127
listener, err := r.conf.HTTP.ToListener()
128128
if err != nil {
@@ -133,13 +133,13 @@ func (r *lokiReceiver) startHTTPServer(host component.Host) error {
133133
go func() {
134134
defer r.shutdownWG.Done()
135135
if errHTTP := r.serverHTTP.Serve(listener); !errors.Is(errHTTP, http.ErrServerClosed) && errHTTP != nil {
136-
host.ReportFatalError(errHTTP)
136+
r.settings.ReportStatus(component.NewFatalErrorEvent(errHTTP))
137137
}
138138
}()
139139
return nil
140140
}
141141

142-
func (r *lokiReceiver) startGRPCServer(host component.Host) error {
142+
func (r *lokiReceiver) startGRPCServer() error {
143143
r.settings.Logger.Info("Starting GRPC server", zap.String("endpoint", r.conf.GRPC.NetAddr.Endpoint))
144144
listener, err := r.conf.GRPC.ToListener()
145145
if err != nil {
@@ -150,7 +150,7 @@ func (r *lokiReceiver) startGRPCServer(host component.Host) error {
150150
go func() {
151151
defer r.shutdownWG.Done()
152152
if errGRPC := r.serverGRPC.Serve(listener); !errors.Is(errGRPC, grpc.ErrServerStopped) && errGRPC != nil {
153-
host.ReportFatalError(errGRPC)
153+
r.settings.ReportStatus(component.NewFatalErrorEvent(errGRPC))
154154
}
155155
}()
156156
return nil

0 commit comments

Comments
 (0)