We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cfc001c commit f82921fCopy full SHA for f82921f
x-pack/metricbeat/mbreceiver/receiver.go
@@ -21,11 +21,14 @@ type metricbeatReceiver struct {
21
}
22
23
func (mb *metricbeatReceiver) Start(ctx context.Context, host component.Host) error {
24
+ if err := mb.BeatReceiver.Setup(host); err != nil {
25
+ return err
26
+ }
27
mb.wg.Add(1)
28
go func() {
29
defer mb.wg.Done()
30
mb.Logger.Info("starting metricbeat receiver")
- if err := mb.BeatReceiver.Start(host); err != nil {
31
+ if err := mb.BeatReceiver.Run(); err != nil {
32
mb.Logger.Error("error starting metricbeat receiver", zap.Error(err))
33
34
}()
0 commit comments