Skip to content

Commit

Permalink
Cleanup code
Browse files Browse the repository at this point in the history
Signed-off-by: Tim Vaillancourt <tim@timvaillancourt.com>
  • Loading branch information
timvaillancourt committed Jul 7, 2023
1 parent 70779b2 commit af95867
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 9 deletions.
10 changes: 5 additions & 5 deletions http.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,9 @@ import (
"github.com/slackhq/nebula/config"
)

func startHttp(l *logrus.Logger, c *config.C, statsHandler statsHandlerFunc, listen string) (f func(), err error) {
// startHttp returns a function to start an http server with pprof support and optionally, a provided stats
// http handler.
func startHttp(l *logrus.Logger, c *config.C, listen string, statsHandler statsHandlerFunc) (func(), error) {
if listen == "" {
return nil, nil
}
Expand All @@ -22,13 +24,11 @@ func startHttp(l *logrus.Logger, c *config.C, statsHandler statsHandlerFunc, lis
}
}

f = func() {
return func() {
l.Infof("Go pprof handler listening on %s at /debug/pprof", listen)
if statsHandler != nil {
http.Handle(statsPath, statsHandler(listen, statsPath))
}
l.Fatal(http.ListenAndServe(listen, nil))
}

return f, err
}, nil
}
2 changes: 1 addition & 1 deletion main.go
Original file line number Diff line number Diff line change
Expand Up @@ -338,7 +338,7 @@ func Main(c *config.C, configTest bool, buildVersion string, logger *logrus.Logg
return nil, util.NewContextualError("Failed to start stats emitter", nil, err)
}

httpStart, err := startHttp(l, c, statsHTTPHandler, httpListen)
httpStart, err := startHttp(l, c, httpListen, statsHTTPHandler)
if err != nil {
return nil, util.NewContextualError("Failed to start http server", nil, err)
}
Expand Down
6 changes: 3 additions & 3 deletions stats.go
Original file line number Diff line number Diff line change
Expand Up @@ -107,13 +107,13 @@ func startPrometheusStats(l *logrus.Logger, i time.Duration, c *config.C, listen
pr.MustRegister(g)
g.Set(1)

var f statsHandlerFunc
var startHandler statsHandlerFunc
if !configTest {
f = func(listen, path string) http.Handler {
startHandler = func(listen, path string) http.Handler {
l.Infof("Prometheus stats listening on %s at %s", listen, path)
return promhttp.HandlerFor(pr, promhttp.HandlerOpts{ErrorLog: l})
}
}

return f, nil
return startHandler, nil
}

0 comments on commit af95867

Please sign in to comment.