chore: remove diagnostics server from manager

Author: pmalek

controller/controlplane/controller.go

@@ -370,7 +370,6 @@ func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Resu
 			}
 
 			mgrCfg := managercfg.NewConfig(cfgOpts...)
-			mgrCfg.DisableRunningDiagnosticsServer = true
 
 			if err := r.scheduleInstance(ctx, logger, mgrID, mgrCfg); err != nil {
 				return r.handleScheduleInstanceOutcome(ctx, logger, cp, err)
@@ -395,7 +394,6 @@ func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Resu
 		}
 
 		mgrCfg := managercfg.NewConfig(cfgOpts...)
-		mgrCfg.DisableRunningDiagnosticsServer = true
 
 		hashFromSpec, errSpec := managercfg.Hash(mgrCfg)
 		if errSpec != nil {

ingress-controller/internal/manager/run.go

@@ -61,7 +61,6 @@ type Manager struct {
 	cfg                  managercfg.Config
 	m                    manager.Manager
 	synchronizer         *dataplane.Synchronizer
-	diagnosticsServer    mo.Option[diagnostics.Server]
 	diagnosticsCollector mo.Option[*diagnostics.Collector]
 	diagnosticsHandler   mo.Option[*diagnostics.HTTPHandler]
 	kubeconfig           *rest.Config
@@ -483,22 +482,12 @@ func (m *Manager) setupDiagnostics(
 		return mo.None[diagnostics.Client]()
 	}
 
-	var serverOpts []diagnostics.ServerOption
 	// If config dumps are enabled, we need to create a diagnostics collector, setup an HTTP handler exposing its
 	// diagnostics, and pass it to the server options so it's plugged in.
 	if c.EnableConfigDumps {
 		diagnosticsCollector := diagnostics.NewCollector(logger, c)
 		m.diagnosticsCollector = mo.Some(diagnosticsCollector)
 		m.diagnosticsHandler = mo.Some(diagnostics.NewConfigDiagnosticsHTTPHandler(diagnosticsCollector, c.DumpSensitiveConfig))
-		serverOpts = append(serverOpts, diagnostics.WithConfigDiagnostics(m.diagnosticsHandler.MustGet()))
-	}
-
-	if !c.DisableRunningDiagnosticsServer {
-		m.diagnosticsServer = mo.Some(diagnostics.NewServer(logger, diagnostics.ServerConfig{
-			ProfilingEnabled:    c.EnableProfiling,
-			DumpSensitiveConfig: c.DumpSensitiveConfig,
-			ListenerPort:        c.DiagnosticServerPort,
-		}, serverOpts...))
 	}
 
 	// If diagnosticsCollector is set, it means that config dumps are enabled and we should return a diagnostics.Client.
@@ -515,15 +504,6 @@ func (m *Manager) Run(ctx context.Context) error {
 	logger := ctrl.LoggerFrom(ctx)
 	logger.Info("Starting manager")
 
-	if ds, ok := m.diagnosticsServer.Get(); ok {
-		go func() {
-			logger.Info("Starting diagnostics server")
-			if err := ds.Listen(ctx); err != nil {
-				logger.Error(err, "Diagnostics server exited")
-			}
-		}()
-	}
-
 	if dc, ok := m.diagnosticsCollector.Get(); ok {
 		go func() {
 			logger.Info("Starting diagnostics collector")

ingress-controller/pkg/manager/config/config.go

@@ -278,9 +278,6 @@ type Config struct {
 	EnableConfigDumps    bool
 	DumpSensitiveConfig  bool
 	DiagnosticServerPort int
-	// TODO: https://github.com/Kong/kubernetes-ingress-controller/issues/7285
-	// instead of this toggle, move the server out of the internal.Manager
-	DisableRunningDiagnosticsServer bool
 
 	// EnableDrainSupport controls whether to include terminating endpoints in Kong upstreams
 	// with weight=0 for graceful connection draining

ingress-controller/test/envtest/run.go

@@ -131,7 +131,6 @@ func WithDiagnosticsServer(port int) func(cfg *managercfg.Config) {
 func WithDiagnosticsWithoutServer() func(cfg *managercfg.Config) {
 	return func(cfg *managercfg.Config) {
 		cfg.EnableConfigDumps = true
-		cfg.DisableRunningDiagnosticsServer = true
 	}
 }