We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b157815 commit 826c907Copy full SHA for 826c907
1 file changed
x-pack/metricbeat/mbreceiver/receiver.go
@@ -34,7 +34,7 @@ func (mb *metricbeatReceiver) Start(ctx context.Context, host component.Host) er
34
35
func (mb *metricbeatReceiver) Shutdown(ctx context.Context) error {
36
mb.Logger.Info("stopping metricbeat receiver")
37
- if err := mb.BeatReceiver.Shutdown(); err != nil {
+ if err := mb.BeatReceiver.Shutdown(ctx); err != nil {
38
return fmt.Errorf("error stopping monitoring server: %w", err)
39
}
40
mb.wg.Wait()
0 commit comments