Skip to content

Commit bd34e21

Browse files
committed
fix: shutdown metrics http-server on context done
1 parent f36cf0e commit bd34e21

File tree

4 files changed

+6
-4
lines changed

4 files changed

+6
-4
lines changed

rolling-shutter/keyper/keyper.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,6 @@ func (kpr *keyper) Start(ctx context.Context, runner service.Runner) error {
119119
if kpr.config.Metrics.Enabled {
120120
epochkghandler.InitMetrics()
121121
kpr.metricsServer = metricsserver.New(kpr.config.Metrics)
122-
runner.Defer(kpr.metricsServer.Shutdown)
123122
}
124123

125124
kpr.dbpool = dbpool

rolling-shutter/medley/metricsserver/metricsserver.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ func New(config *MetricsConfig) *MetricsServer {
2222
return &MetricsServer{config: config, mux: http.NewServeMux()}
2323
}
2424

25-
func (srv *MetricsServer) Start(_ context.Context, group service.Runner) error {
25+
func (srv *MetricsServer) Start(ctx context.Context, group service.Runner) error { //nolint:unparam
2626
group.Go(func() error {
2727
srv.mux.Handle("/metrics", promhttp.Handler())
2828
addr := fmt.Sprintf("%s:%d", srv.config.Host, srv.config.Port)
@@ -39,6 +39,11 @@ func (srv *MetricsServer) Start(_ context.Context, group service.Runner) error {
3939
}
4040
return nil
4141
})
42+
group.Go(func() error {
43+
<-ctx.Done()
44+
srv.Shutdown()
45+
return ctx.Err()
46+
})
4247
return nil
4348
}
4449

rolling-shutter/snapshot/snapshot.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,6 @@ func (snp *Snapshot) Start(ctx context.Context, runner service.Runner) error {
8686
return err
8787
}
8888
snp.metricsServer = metricsserver.New(snp.Config.Metrics)
89-
runner.Defer(snp.metricsServer.Shutdown)
9089
}
9190

9291
hub := hubapi.New(snp.Config.SnapshotHubURL)

rolling-shutter/snapshotkeyper/snapshotkeyper.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,6 @@ func (snkpr *snapshotkeyper) Start(ctx context.Context, runner service.Runner) e
9090
if snkpr.config.Metrics.Enabled {
9191
epochkghandler.InitMetrics()
9292
snkpr.metricsServer = metricsserver.New(snkpr.config.Metrics)
93-
runner.Defer(snkpr.metricsServer.Shutdown)
9493
}
9594

9695
snkpr.dbpool = dbpool

0 commit comments

Comments
 (0)