diff --git a/control-plane/subcommand/sync-catalog/command.go b/control-plane/subcommand/sync-catalog/command.go index e262535423..b14f323dde 100644 --- a/control-plane/subcommand/sync-catalog/command.go +++ b/control-plane/subcommand/sync-catalog/command.go @@ -210,6 +210,18 @@ func (c *Command) Run(args []string) int { } } + // Start healthcheck handler + go func() { + mux := http.NewServeMux() + mux.HandleFunc("/health/ready", c.handleReady) + var handler http.Handler = mux + + c.UI.Info(fmt.Sprintf("Listening on %q...", c.flagListen)) + if err := http.ListenAndServe(c.flagListen, handler); err != nil { + c.UI.Error(fmt.Sprintf("Error listening: %s", err)) + } + }() + // Convert allow/deny lists to sets allowSet := flags.ToSet(c.flagAllowK8sNamespacesList) denySet := flags.ToSet(c.flagDenyK8sNamespacesList) @@ -329,18 +341,6 @@ func (c *Command) Run(args []string) int { }() } - // Start healthcheck handler - go func() { - mux := http.NewServeMux() - mux.HandleFunc("/health/ready", c.handleReady) - var handler http.Handler = mux - - c.UI.Info(fmt.Sprintf("Listening on %q...", c.flagListen)) - if err := http.ListenAndServe(c.flagListen, handler); err != nil { - c.UI.Error(fmt.Sprintf("Error listening: %s", err)) - } - }() - select { // Unexpected exit case <-toConsulCh: