chore: reduce info log verbosity in all services (#2170)

Signed-off-by: Alessandro Yuichi Okimoto <yuichijpn@gmail.com>

Author: cre8ivejp

manifests/bucketeer/charts/batch/templates/cronjob.yaml

@@ -65,11 +65,8 @@ spec:
                   rm -f ${RESPONSE}
                   END_TIME=$(date +%s)
                   DURATION=$((END_TIME - START_TIME))
-                  # API returns empty {} on success, or error details on failure
-                  if [ "${RES}" = "200" ]; then
-                    # Success - use DEBUG to avoid verbose logs
-                    echo '{"severity":"DEBUG","message":"'${JOB_NAME}' job completed successfully","job":"'${JOB_NAME}'","jobId":"'${JOB_ID}'","statusCode":'${RES}',"durationSeconds":'${DURATION}'}'
-                  else
+                  # Only log on failure - success is silent
+                  if [ "${RES}" != "200" ]; then
                     # Failure - log as ERROR with response details for debugging
                     BODY_ESCAPED=$(echo "${BODY}" | sed 's/\\/\\\\/g; s/"/\\"/g' | tr '\n\r\t' '   ')
                     echo '{"severity":"ERROR","message":"'${JOB_NAME}' job failed","job":"'${JOB_NAME}'","jobId":"'${JOB_ID}'","statusCode":'${RES}',"durationSeconds":'${DURATION}',"responseBody":"'${BODY_ESCAPED}'"}'

pkg/api/cmd/server.go

@@ -566,7 +566,6 @@ func (s *server) Run(ctx context.Context, metrics metrics.Metrics, logger *zap.L
 
 	defer func() {
 		shutdownStartTime := time.Now()
-		logger.Info("Starting graceful shutdown sequence")
 
 		// Wait for K8s endpoint propagation
 		// This prevents "context deadline exceeded" errors during high traffic.

pkg/batch/cmd/server/server.go

@@ -631,7 +631,6 @@ func (s *server) Run(ctx context.Context, metrics metrics.Metrics, logger *zap.L
 
 	defer func() {
 		shutdownStartTime := time.Now()
-		logger.Info("Starting graceful shutdown sequence")
 
 		// Wait for K8s endpoint propagation
 		// This prevents "context deadline exceeded" errors during high traffic.

pkg/rpc/server.go

@@ -139,27 +139,18 @@ func (s *Server) Run() {
 }
 
 func (s *Server) Stop(timeout time.Duration) {
-	shutdownStart := time.Now()
-	s.logger.Info("Starting server graceful shutdown",
-		zap.String("server", s.name),
-		zap.Duration("timeout", timeout))
-
 	// Shutdown order is critical:
 	// 1. HTTP server first (drains REST/gRPC-Gateway requests)
 	// 2. gRPC server second (only pure gRPC connections remain)
 	//
 	// This ensures HTTP requests that call s.rpcServer.ServeHTTP() can complete
 	// before we stop the underlying gRPC server.
 	if s.httpServer != nil {
-		s.logger.Info("Starting HTTP server graceful shutdown")
-
 		ctx, cancel := context.WithTimeout(context.Background(), timeout)
 		defer cancel()
 
 		if err := s.httpServer.Shutdown(ctx); err != nil {
 			s.logger.Error("HTTP server failed to shut down gracefully", zap.Error(err))
-		} else {
-			s.logger.Info("HTTP server shutdown completed gracefully")
 		}
 	}
 
@@ -168,13 +159,8 @@ func (s *Server) Stop(timeout time.Duration) {
 	// - HTTP-served connections were already drained in step 1
 	// - Pure gRPC clients have retry logic and Envoy connection draining to handle this
 	if s.rpcServer != nil {
-		s.logger.Info("Stopping gRPC server")
 		s.rpcServer.Stop()
 	}
-
-	s.logger.Info("Server shutdown completed",
-		zap.String("server", s.name),
-		zap.Duration("total_duration", time.Since(shutdownStart)))
 }
 
 func (s *Server) setupRPC() {

pkg/subscriber/cmd/server/server.go

@@ -362,7 +362,6 @@ func (s *server) Run(ctx context.Context, metrics metrics.Metrics, logger *zap.L
 
 	defer func() {
 		shutdownStartTime := time.Now()
-		logger.Info("Starting graceful shutdown sequence")
 
 		// Mark as unhealthy so readiness probes fail
 		// This ensures Kubernetes readiness probe fails on next check,

pkg/web/cmd/server/server.go

@@ -860,7 +860,6 @@ func (s *server) Run(ctx context.Context, metrics metrics.Metrics, logger *zap.L
 
 	defer func() {
 		shutdownStartTime := time.Now()
-		logger.Info("Starting graceful shutdown sequence")
 
 		// Wait for K8s endpoint propagation
 		// This prevents "context deadline exceeded" errors during high traffic.