adding processHandler struct update

Author: miledxz

internal/mode/static/manager.go

@@ -63,6 +63,7 @@ const (
 )
 
 var scheme = runtime.NewScheme()
+var proccesHandler = &ngxruntime.ProcessHandlerImpl{}
 
 func init() {
 	utilruntime.Must(gatewayv1beta1.Install(scheme))
@@ -134,9 +135,12 @@ func StartManager(cfg config.Config) error {
 	}
 
 	// Ensure NGINX is running before registering metrics & starting the manager.
-	if err := ngxruntime.EnsureNginxRunning(ctx, &ngxruntime.ProcessHandlerImpl{}); err != nil {
+	if err := proccesHandler.EnsureNginxRunning(ctx); err != nil {
 		return fmt.Errorf("NGINX is not running: %w", err)
 	}
+	//if err := ngxruntime.EnsureNginxRunning(ctx, &ngxruntime.ProcessHandlerImpl{}); err != nil {
+	//	return fmt.Errorf("NGINX is not running: %w", err)
+	//}
 
 	var (
 		ngxruntimeCollector ngxruntime.MetricsCollector = collectors.NewManagerNoopCollector()
@@ -211,7 +215,7 @@ func StartManager(cfg config.Config) error {
 			ngxPlusClient,
 			ngxruntimeCollector,
 			cfg.Logger.WithName("nginxRuntimeManager"),
-			&ngxruntime.ProcessHandlerImpl{},
+			proccesHandler,
 			ngxruntime.NewVerifyClient(ngxruntime.NginxReloadTimeout),
 		),
 		statusUpdater:                 groupStatusUpdater,

internal/mode/static/nginx/runtime/manager.go

@@ -36,12 +36,13 @@ type nginxPlusClient interface {
 	GetUpstreams() (*ngxclient.Upstreams, error)
 }
 
-//go:generate go run github.com/maxbrunsfeld/counterfeiter/v6 . processHandler
+//go:generate go run github.com/maxbrunsfeld/counterfeiter/v6 . ProcessHandler
 
 type ProcessHandler interface {
 	FindMainProcess(ctx context.Context, checkFile CheckFileFunc, readFile ReadFileFunc, timeout time.Duration) (int, error)
 	ReadFile(file string) ([]byte, error)
 	Kill(pid int, signum syscall.Signal) error
+	EnsureNginxRunning(ctx context.Context) error
 }
 
 type ProcessHandlerImpl struct {
@@ -176,8 +177,8 @@ func (m *ManagerImpl) GetUpstreams() (ngxclient.Upstreams, error) {
 }
 
 // EnsureNginxRunning ensures NGINX is running by locating the main process.
-func EnsureNginxRunning(ctx context.Context, processHandler ProcessHandler) error {
-	if _, err := processHandler.FindMainProcess(ctx, os.Stat, os.ReadFile, pidFileTimeout); err != nil {
+func (p *ProcessHandlerImpl) EnsureNginxRunning(ctx context.Context) error {
+	if _, err := p.FindMainProcess(ctx, os.Stat, os.ReadFile, pidFileTimeout); err != nil {
 		return fmt.Errorf("failed to find NGINX main process: %w", err)
 	}
 	return nil