chore: remove diagnostics server from manager

Author: pmalek

controller/controlplane/controller.go

@@ -376,7 +376,6 @@ func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Resu
 			if err != nil {
 				return ctrl.Result{}, fmt.Errorf("failed to create manager config: %w", err)
 			}
-			mgrCfg.DisableRunningDiagnosticsServer = true
 			if err := r.scheduleInstance(ctx, logger, mgrID, mgrCfg); err != nil {
 				return r.handleScheduleInstanceOutcome(ctx, logger, cp, err)
 			}
@@ -403,7 +402,6 @@ func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Resu
 		if err != nil {
 			return ctrl.Result{}, fmt.Errorf("failed to create manager config: %w", err)
 		}
-		mgrCfg.DisableRunningDiagnosticsServer = true
 		hashFromSpec, errSpec := managercfg.Hash(mgrCfg)
 		if errSpec != nil {
 			return ctrl.Result{}, fmt.Errorf("failed to hash ControlPlane config options: %w", errSpec)

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]
 	admissionServer      mo.Option[*admission.Server]
@@ -487,14 +486,6 @@ func (m *Manager) setupDiagnostics(
 		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.
 	if dc, ok := m.diagnosticsCollector.Get(); ok {
 		return mo.Some(dc.Client())
@@ -509,15 +500,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

@@ -135,9 +135,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
 	}
 }