chore: verbose logging

Signed-off-by: Timur Tuktamyshev <[email protected]>

Author: timmilesdw

hooks/pods-hook.sh

@@ -5,8 +5,10 @@ import (
 	"fmt"
 	"io"
 	"log/slog"
+	"net"
 	"net/http"
 	"os"
+	"path"
 	"path/filepath"
 	"strings"
 
@@ -15,6 +17,7 @@ import (
 	"github.com/go-chi/chi/v5/middleware"
 	"gopkg.in/yaml.v3"
 
+	utils "github.com/flant/shell-operator/pkg/utils/file"
 	structuredLogger "github.com/flant/shell-operator/pkg/utils/structured-logger"
 )
 
@@ -44,37 +47,37 @@ func NewServer(prefix, socketPath, httpAddr string, logger *log.Logger) *Server
 }
 
 func (s *Server) Init() error {
-	// address := s.SocketPath
-
-	// if err := os.MkdirAll(path.Dir(address), 0o700); err != nil {
-	// 	return fmt.Errorf("Debug HTTP server fail to create socket '%s': %w", address, err)
-	// }
-
-	// exists, err := utils.FileExists(address)
-	// if err != nil {
-	// 	return fmt.Errorf("Debug HTTP server fail to check socket '%s': %w", address, err)
-	// }
-
-	// if exists {
-	// 	if err := os.Remove(address); err != nil {
-	// 		return fmt.Errorf("Debug HTTP server fail to check socket '%s': %w", address, err)
-	// 	}
-	// }
-
-	// // Check if socket is available
-	// listener, err := net.Listen("unix", address)
-	// if err != nil {
-	// 	return fmt.Errorf("Debug HTTP server fail to listen on '%s': %w", address, err)
-	// }
-
-	// s.logger.Info("Debug endpoint listen on address", slog.String("address", address))
-
-	// go func() {
-	// 	if err := http.Serve(listener, s.Router); err != nil {
-	// 		s.logger.Error("Error starting Debug socket server", log.Err(err))
-	// 		os.Exit(1)
-	// 	}
-	// }()
+	address := s.SocketPath
+
+	if err := os.MkdirAll(path.Dir(address), 0o700); err != nil {
+		return fmt.Errorf("Debug HTTP server fail to create socket '%s': %w", address, err)
+	}
+
+	exists, err := utils.FileExists(address)
+	if err != nil {
+		return fmt.Errorf("Debug HTTP server fail to check socket '%s': %w", address, err)
+	}
+
+	if exists {
+		if err := os.Remove(address); err != nil {
+			return fmt.Errorf("Debug HTTP server fail to check socket '%s': %w", address, err)
+		}
+	}
+
+	// Check if socket is available
+	listener, err := net.Listen("unix", address)
+	if err != nil {
+		return fmt.Errorf("Debug HTTP server fail to listen on '%s': %w", address, err)
+	}
+
+	s.logger.Info("Debug endpoint listen on address", slog.String("address", address))
+
+	go func() {
+		if err := http.Serve(listener, s.Router); err != nil {
+			s.logger.Error("Error starting Debug socket server", log.Err(err))
+			os.Exit(1)
+		}
+	}()
 
 	if s.HttpAddr != "" {
 		go func() {

pkg/debug/server.go

@@ -960,20 +960,20 @@ func (op *ShellOperator) runMetrics() {
 
 // Shutdown pause kubernetes events handling and stop queues. Wait for queues to stop.
 func (op *ShellOperator) Shutdown() {
-	log.Info("shutdown: begin")
+	log.Info("shutdown begin", slog.String("phase", "shutdown"))
 	op.ScheduleManager.Stop()
-	log.Info("shutdown: schedule manager stopped")
+	log.Info("schedule manager stopped", slog.String("phase", "shutdown"))
 
 	op.KubeEventsManager.Stop()
-	log.Info("shutdown: kube events manager canceled, waiting for informers")
+	log.Info("waiting informers", slog.String("phase", "shutdown"))
 	if kem, ok := op.KubeEventsManager.(interface{ Wait() }); ok {
 		kem.Wait()
 	}
-	log.Info("shutdown: kube events manager done")
+	log.Info("informers stopped", slog.String("phase", "shutdown"))
 
 	op.TaskQueues.Stop()
-	log.Info("shutdown: task queues stop signaled, waiting")
+	log.Info("waiting task queues", slog.String("phase", "shutdown"))
 	// Wait for queues to stop, but no more than 10 seconds
 	op.TaskQueues.WaitStopWithTimeout(WaitQueuesTimeout)
-	log.Info("shutdown: task queues stopped")
+	log.Info("task queues stopped", slog.String("phase", "shutdown"))
 }