From 6817e8281d1be34da9f142d3272553b49c21eef3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Tom=C3=A1=C5=A1=20Reme=C5=A1?= Date: Wed, 21 Jul 2021 09:39:10 +0200 Subject: [PATCH] Update --- pkg/cmd/start/start.go | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/pkg/cmd/start/start.go b/pkg/cmd/start/start.go index 5d7bbf97b..99f203021 100644 --- a/pkg/cmd/start/start.go +++ b/pkg/cmd/start/start.go @@ -69,15 +69,15 @@ func NewGather() *cobra.Command { func runGather(operator *controller.GatherJob, cfg *controllercmd.ControllerCommandConfig) func(cmd *cobra.Command, args []string) { return func(cmd *cobra.Command, args []string) { if configArg := cmd.Flags().Lookup("config").Value.String(); len(configArg) == 0 { - klog.Error("error: --config is required") + klog.Exit("error: --config is required") } unstructured, _, _, err := cfg.Config() if err != nil { - klog.Error(err) + klog.Exit(err) } cont, err := config.LoadConfig(operator.Controller, unstructured.Object, config.ToDisconnectedController) if err != nil { - klog.Error(err) + klog.Exit(err) } operator.Controller = cont @@ -85,20 +85,20 @@ func runGather(operator *controller.GatherJob, cfg *controllercmd.ControllerComm if kubeConfigPath := cmd.Flags().Lookup("kubeconfig").Value.String(); len(kubeConfigPath) > 0 { kubeConfigBytes, err := ioutil.ReadFile(kubeConfigPath) //nolint: govet if err != nil { - klog.Error(err) + klog.Exit(err) } kubeConfig, err := clientcmd.NewClientConfigFromBytes(kubeConfigBytes) if err != nil { - klog.Error(err) + klog.Exit(err) } clientConfig, err = kubeConfig.ClientConfig() if err != nil { - klog.Error(err) + klog.Exit(err) } } else { clientConfig, err = rest.InClusterConfig() if err != nil { - klog.Error(err) + klog.Exit(err) } } protoConfig := rest.CopyConfig(clientConfig) @@ -125,17 +125,17 @@ func runOperator(operator *controller.Operator, cfg *controllercmd.ControllerCom serviceability.StartProfiler() if configArg := cmd.Flags().Lookup("config").Value.String(); len(configArg) == 0 { - klog.Error("error: --config is required") + klog.Exit("error: --config is required") } unstructured, operatorConfig, configBytes, err := cfg.Config() if err != nil { - klog.Error(err) + klog.Exit(err) } startingFileContent, observedFiles, err := cfg.AddDefaultRotationToConfig(operatorConfig, configBytes) if err != nil { - klog.Error(err) + klog.Exit(err) } // if the service CA is rotated, we want to restart