Merge pull request #36 from Oats87/check-k8s-version

Check K8s cluster is healthy before proceeding to watch for remote K8s plans
rancher · Jun 16, 2021 · 7a0bea5 · 7a0bea5
2 parents 58799bb + 5777eca
commit 7a0bea5
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/k8splan/watcher.go b/pkg/k8splan/watcher.go
@@ -56,6 +56,10 @@ func (w *watcher) start(ctx context.Context) {
 		panic(err)
 	}
 
+	if !clientFactory.IsHealthy(ctx) {
+		panic(fmt.Errorf("error while connecting to Kubernetes cluster"))
+	}
+
 	cacheFactory := cache.NewSharedCachedFactory(clientFactory, &cache.SharedCacheFactoryOptions{
 		DefaultNamespace: w.connInfo.Namespace,
 		DefaultTweakList: func(options *metav1.ListOptions) {