Error and exit on failure

Signed-off-by: Yuriy Losev <yuriy.losev@flant.com>

Author: yalosev

vertical-pod-autoscaler/pkg/admission-controller/main.go

@@ -120,9 +120,10 @@ func main() {
 	defer close(stopCh)
 	factory.Start(stopCh)
 	informerMap := factory.WaitForCacheSync(stopCh)
-	for informerType, synced := range informerMap {
+	for kind, synced := range informerMap {
 		if !synced {
-			klog.V(0).InfoS("Initial sync failed", "kind", informerType)
+			klog.ErrorS(nil, fmt.Sprintf("Could not sync cache for the %s informer", kind.String()))
+			klog.FlushAndExit(klog.ExitFlushTimeout, 1)
 		}
 	}
 

vertical-pod-autoscaler/pkg/recommender/main.go

@@ -19,6 +19,7 @@ package main
 import (
 	"context"
 	"flag"
+	"fmt"
 	"os"
 	"strings"
 	"time"
@@ -234,9 +235,10 @@ func run(ctx context.Context, healthCheck *metrics.HealthCheck, commonFlag *comm
 
 	factory.Start(stopCh)
 	informerMap := factory.WaitForCacheSync(stopCh)
-	for informerType, synced := range informerMap {
+	for kind, synced := range informerMap {
 		if !synced {
-			klog.V(0).InfoS("Initial sync failed", "kind", informerType)
+			klog.ErrorS(nil, fmt.Sprintf("Could not sync cache for the %s informer", kind.String()))
+			klog.FlushAndExit(klog.ExitFlushTimeout, 1)
 		}
 	}
 

vertical-pod-autoscaler/pkg/updater/main.go

@@ -19,6 +19,7 @@ package main
 import (
 	"context"
 	"flag"
+	"fmt"
 	"os"
 	"strings"
 	"time"
@@ -189,9 +190,10 @@ func run(healthCheck *metrics.HealthCheck, commonFlag *common.CommonFlags) {
 
 	factory.Start(stopCh)
 	informerMap := factory.WaitForCacheSync(stopCh)
-	for informerType, synced := range informerMap {
+	for kind, synced := range informerMap {
 		if !synced {
-			klog.V(0).InfoS("Initial sync failed", "kind", informerType)
+			klog.ErrorS(nil, fmt.Sprintf("Could not sync cache for the %s informer", kind.String()))
+			klog.FlushAndExit(klog.ExitFlushTimeout, 1)
 		}
 	}