Use Kubernetes API batch/v1beta1 instead of batch/v2alpha1

Gopkg.toml

@@ -1,10 +1,3 @@
-[[constraint]]
-  name = "k8s.io/apimachinery"
-  branch = "release-1.7"
-
-[[constraint]]
-  name = "k8s.io/client-go"
-  version = "4.0.0"
 
 [[override]]
   name = "github.com/ugorji/go"

cluster/kubernetes/kubernetes.go

@@ -9,16 +9,15 @@ import (
 	"github.com/go-kit/kit/log"
 	"github.com/pkg/errors"
 	"gopkg.in/yaml.v2"
+	apiv1 "k8s.io/api/core/v1"
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/discovery"
 	k8sclient "k8s.io/client-go/kubernetes"
 	v1beta1apps "k8s.io/client-go/kubernetes/typed/apps/v1beta1"
-	v2alpha1batch "k8s.io/client-go/kubernetes/typed/batch/v2alpha1"
+	v1beta1batch "k8s.io/client-go/kubernetes/typed/batch/v1beta1"
 	v1core "k8s.io/client-go/kubernetes/typed/core/v1"
 	v1beta1extensions "k8s.io/client-go/kubernetes/typed/extensions/v1beta1"
-	"k8s.io/client-go/pkg/api"
-	apiv1 "k8s.io/client-go/pkg/api/v1"
 
 	"github.com/weaveworks/flux"
 	"github.com/weaveworks/flux/cluster"
@@ -38,7 +37,7 @@ type extendedClient struct {
 	v1core.CoreV1Interface
 	v1beta1extensions.ExtensionsV1beta1Interface
 	v1beta1apps.StatefulSetsGetter
-	v2alpha1batch.CronJobsGetter
+	v1beta1batch.CronJobsGetter
 }
 
 type apiObject struct {
@@ -138,7 +137,7 @@ func NewCluster(clientset k8sclient.Interface,
 			clientset.Core(),
 			clientset.Extensions(),
 			clientset.AppsV1beta1(),
-			clientset.BatchV2alpha1(),
+			clientset.BatchV1beta1(),
 		},
 		applier:    applier,
 		logger:     logger,
@@ -331,11 +330,11 @@ func mergeCredentials(c *Cluster, namespace string, podTemplate apiv1.PodTemplat
 		var ok bool
 		// These differ in format; but, ParseCredentials will
 		// handle either.
-		switch api.SecretType(secret.Type) {
-		case api.SecretTypeDockercfg:
-			decoded, ok = secret.Data[api.DockerConfigKey]
-		case api.SecretTypeDockerConfigJson:
-			decoded, ok = secret.Data[api.DockerConfigJsonKey]
+		switch apiv1.SecretType(secret.Type) {
+		case apiv1.SecretTypeDockercfg:
+			decoded, ok = secret.Data[apiv1.DockerConfigKey]
+		case apiv1.SecretTypeDockerConfigJson:
+			decoded, ok = secret.Data[apiv1.DockerConfigJsonKey]
 		default:
 			c.logger.Log("skip", "unknown type", "secret", namespace+"/"+secret.Name, "type", secret.Type)
 			continue

cluster/kubernetes/resourcekinds.go

@@ -3,11 +3,11 @@ package kubernetes
 import (
 	"fmt"
 
+	apiapps "k8s.io/api/apps/v1beta1"
+	apibatch "k8s.io/api/batch/v1beta1"
+	apiv1 "k8s.io/api/core/v1"
+	apiext "k8s.io/api/extensions/v1beta1"
 	meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	apiv1 "k8s.io/client-go/pkg/api/v1"
-	apiapps "k8s.io/client-go/pkg/apis/apps/v1beta1"
-	apibatch "k8s.io/client-go/pkg/apis/batch/v2alpha1"
-	apiext "k8s.io/client-go/pkg/apis/extensions/v1beta1"
 
 	"github.com/weaveworks/flux"
 	"github.com/weaveworks/flux/cluster"
@@ -222,7 +222,7 @@ func makeStatefulSetPodController(statefulSet *apiapps.StatefulSet) podControlle
 }
 
 /////////////////////////////////////////////////////////////////////////////
-// batch/v2alpha1 CronJob
+// batch/v1beta1 CronJob
 
 type cronJobKind struct{}
 
@@ -251,7 +251,7 @@ func (dk *cronJobKind) getPodControllers(c *Cluster, namespace string) ([]podCon
 
 func makeCronJobPodController(cronJob *apibatch.CronJob) podController {
 	return podController{
-		apiVersion:  "batch/v2alpha1",
+		apiVersion:  "batch/v1beta1",
 		kind:        "CronJob",
 		name:        cronJob.ObjectMeta.Name,
 		status:      StatusReady,