diff --git a/pkg/client/client.go b/pkg/client/client.go index 3e8a16f..4695819 100644 --- a/pkg/client/client.go +++ b/pkg/client/client.go @@ -56,11 +56,14 @@ func InitClient() *kubernetes.Clientset { flag.Parse() - config = clientcmd.NewNonInteractiveDeferredLoadingClientConfig( + config, err := clientcmd.NewNonInteractiveDeferredLoadingClientConfig( &clientcmd.ClientConfigLoadingRules{ExplicitPath: *kubeconfig}, &clientcmd.ConfigOverrides{ - CurrentContext: *context, + CurrentContext: *kubecontext, }).ClientConfig() + if err != nil { + panic(err.Error()) + } csBackup, err := getClientSetFromConfig(config) if err != nil { diff --git a/pkg/triage/deployments_triage.go b/pkg/triage/deployments_triage.go index 8a362dd..ef608c2 100644 --- a/pkg/triage/deployments_triage.go +++ b/pkg/triage/deployments_triage.go @@ -1,6 +1,7 @@ package triage import ( + "strings" "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/kubernetes" ) @@ -12,7 +13,7 @@ func OrphanedDeployments(kubeCli *kubernetes.Clientset, namespace string) (*Tria listOfTriages := make([]string, 0) deployments, err := kubeCli.ExtensionsV1beta1().Deployments(namespace).List(v1.ListOptions{}) if err != nil { - if err.Error() != KUBE_RESOURCE_NOT_FOUND { + if ! strings.Contains(err.Error(), KUBE_RESOURCE_NOT_FOUND) { return nil, err } } @@ -31,7 +32,7 @@ func LeftOverDeployments(kubeCli *kubernetes.Clientset, namespace string) (*Tria listOfTriages := make([]string, 0) deployments, err := kubeCli.ExtensionsV1beta1().Deployments(namespace).List(v1.ListOptions{}) if err != nil { - if err.Error() != KUBE_RESOURCE_NOT_FOUND { + if ! strings.Contains(err.Error(), KUBE_RESOURCE_NOT_FOUND) { return nil, err } }