Skip to content

Commit d28d420

Browse files
committed
improve logging
1 parent 0954ba0 commit d28d420

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

cmd/socket-proxy/checksocketconnection.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -13,14 +13,14 @@ const dialTimeout = 5 // timeout in seconds for the socket connection
1313

1414
// checkSocketAvailability tries to connect to the socket and returns an error if it fails.
1515
func checkSocketAvailability(socketPath string) error {
16-
slog.Debug("checking socket availability")
16+
slog.Debug("checking socket availability", "origin", "checkSocketAvailability")
1717
conn, err := net.DialTimeout("unix", socketPath, dialTimeout*time.Second)
1818
if err != nil {
1919
return err
2020
}
2121
err = conn.Close()
2222
if err != nil {
23-
slog.Warn("Watchdog: Error closing socket", "error", err)
23+
slog.Error("error closing socket", "origin", "checkSocketAvailability", "error", err)
2424
}
2525
return nil
2626
}
@@ -32,9 +32,9 @@ func startSocketWatchdog(socketPath string, interval uint, stopOnWatchdog bool)
3232

3333
for range ticker.C {
3434
if err := checkSocketAvailability(socketPath); err != nil {
35-
slog.Warn("Watchdog: Socket is unavailable", "error", err)
35+
slog.Error("socket is unavailable", "origin", "watchdog", "error", err)
3636
if stopOnWatchdog {
37-
slog.Warn("Watchdog: Stopping socket-proxy because of unavailable socket")
37+
slog.Warn("stopping socket-proxy because of unavailable socket", "origin", "watchdog")
3838
os.Exit(10)
3939
}
4040
}
@@ -52,7 +52,7 @@ func healthCheckServer(socketPath string) {
5252
}
5353
err := checkSocketAvailability(socketPath)
5454
if err != nil {
55-
slog.Error("health check failed", "error", err)
55+
slog.Error("health check failed", "origin", "healthcheck", "error", err)
5656
w.WriteHeader(http.StatusServiceUnavailable)
5757
return
5858
}
@@ -68,6 +68,6 @@ func healthCheckServer(socketPath string) {
6868
}
6969

7070
if err := hcSrv.ListenAndServe(); err != nil && !errors.Is(err, http.ErrServerClosed) {
71-
slog.Error("healthcheck http server problem", "error", err)
71+
slog.Error("healthcheck http server problem", "origin", "healthcheck", "error", err)
7272
}
7373
}

0 commit comments

Comments
 (0)