From 067727a3702e677a8364de53683c27b0f0151bdc Mon Sep 17 00:00:00 2001 From: Darren Shepherd Date: Sat, 1 Aug 2020 23:31:51 -0700 Subject: [PATCH] Move k8scheck to wrangler --- pkg/k8scheck/wait.go | 33 --------------------------------- 1 file changed, 33 deletions(-) delete mode 100644 pkg/k8scheck/wait.go diff --git a/pkg/k8scheck/wait.go b/pkg/k8scheck/wait.go deleted file mode 100644 index 4fdb2bba..00000000 --- a/pkg/k8scheck/wait.go +++ /dev/null @@ -1,33 +0,0 @@ -package k8scheck - -import ( - "context" - "fmt" - "time" - - "github.com/sirupsen/logrus" - "k8s.io/client-go/kubernetes" - "k8s.io/client-go/rest" -) - -func Wait(ctx context.Context, config rest.Config) error { - client, err := kubernetes.NewForConfig(&config) - if err != nil { - return err - } - - for { - _, err := client.Discovery().ServerVersion() - if err == nil { - break - } - logrus.Infof("Waiting for server to become available: %v", err) - select { - case <-ctx.Done(): - return fmt.Errorf("startup canceled") - case <-time.After(2 * time.Second): - } - } - - return nil -}