Skip to content

Commit a5efba7

Browse files
Frapschenatoulme
andcommitted
Apply suggestions from code review
Co-authored-by: Antoine Toulme <[email protected]>
1 parent 7f3ffcd commit a5efba7

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

receiver/k8sobjectsreceiver/receiver.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -82,23 +82,22 @@ func (kr *k8sobjectsreceiver) Start(ctx context.Context, host component.Host) er
8282
return fmt.Errorf("unknown k8s leader elector %q", kr.config.K8sLeaderElector)
8383
}
8484

85-
kr.setting.Logger.Info("Trying to become the leader")
85+
kr.setting.Logger.Debug("Trying to become the leader")
8686
elector := k8sLeaderElector.(k8sleaderelector.LeaderElection)
8787
elector.SetCallBackFuncs(
8888
func(_ context.Context) {
89-
kr.setting.Logger.Info("Object Receiver started as leader")
89+
kr.setting.Logger.Info("elected as leader")
9090
for _, object := range kr.config.Objects {
9191
kr.start(cctx, object)
9292
}
9393
},
9494
func() {
95-
kr.setting.Logger.Info("Object Receiver stopped as leader lose")
95+
kr.setting.Logger.Info("no longer leader, stopping")
9696
_ = kr.Shutdown(context.Background())
9797
})
9898
return nil
9999
}
100100

101-
kr.setting.Logger.Info("Object Receiver started")
102101
for _, object := range kr.config.Objects {
103102
kr.start(cctx, object)
104103
}

0 commit comments

Comments
 (0)