Vendored in latest package for cluster-api

go.mod

@@ -91,7 +91,7 @@ require (
 	github.com/kubernetes-csi/external-snapshotter/client/v6 v6.2.0
 	github.com/tektoncd/pipeline v0.56.0
 	google.golang.org/api v0.156.0
-	sigs.k8s.io/cluster-api v0.2.11
+	sigs.k8s.io/cluster-api v1.7.3
 )
 
 require (

k8s/anthos/clusters.go

@@ -5,15 +5,15 @@ import (
 	"encoding/json"
 	"fmt"
 
-	v1alpha1 "sigs.k8s.io/cluster-api/pkg/apis/deprecated/v1alpha1"
+	v1beta1 "sigs.k8s.io/cluster-api/api/v1beta1"
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 )
 
 var (
-	clusterResource = schema.GroupVersionResource{Group: "cluster.k8s.io", Version: "v1alpha1", Resource: "clusters"}
+	clusterResource = schema.GroupVersionResource{Group: "cluster.k8s.io", Version: "v1beta1", Resource: "clusters"}
 )
 
 type IpBlock struct {
@@ -58,17 +58,17 @@ type ClusterProviderConfig struct {
 // ClusterOps is an interface to perform k8s cluster operations
 type ClusterOps interface {
 	// ListCluster lists all kubernetes clusters
-	ListCluster(ctx context.Context) (*v1alpha1.ClusterList, error)
+	ListCluster(ctx context.Context) (*v1beta1.ClusterList, error)
 	// GetCluster returns a cluster for the given name
-	GetCluster(ctx context.Context, name, namespace string) (*v1alpha1.Cluster, error)
+	GetCluster(ctx context.Context, name, namespace string) (*v1beta1.Cluster, error)
 	// GetClusterStatus return the given cluster status
-	GetClusterStatus(ctx context.Context, name, namespace string) (*v1alpha1.ClusterStatus, error)
+	GetClusterStatus(ctx context.Context, name, namespace string) (*v1beta1.ClusterStatus, error)
 	// GetClusterProviderSpec return cluster provider spec
 	GetClusterProviderSpec(ctx context.Context, name, namespace string) (*ClusterProviderConfig, error)
 }
 
 // ListCluster lists all kubernetes clusters
-func (c *Client) ListCluster(ctx context.Context) (*v1alpha1.ClusterList, error) {
+func (c *Client) ListCluster(ctx context.Context) (*v1beta1.ClusterList, error) {
 	if err := c.initClient(); err != nil {
 		return nil, err
 	}
@@ -81,7 +81,7 @@ func (c *Client) ListCluster(ctx context.Context) (*v1alpha1.ClusterList, error)
 	if err != nil {
 		return nil, err
 	}
-	clusterList := &v1alpha1.ClusterList{}
+	clusterList := &v1beta1.ClusterList{}
 	if err := json.Unmarshal(jsonData, clusterList); err != nil {
 		return nil, err
 	}
@@ -90,7 +90,7 @@ func (c *Client) ListCluster(ctx context.Context) (*v1alpha1.ClusterList, error)
 }
 
 // GetCluster returns a cluster for the given name
-func (c *Client) GetCluster(ctx context.Context, name, namespace string) (*v1alpha1.Cluster, error) {
+func (c *Client) GetCluster(ctx context.Context, name, namespace string) (*v1beta1.Cluster, error) {
 	if err := c.initClient(); err != nil {
 		return nil, err
 	}
@@ -102,15 +102,15 @@ func (c *Client) GetCluster(ctx context.Context, name, namespace string) (*v1alp
 	if err != nil {
 		return nil, err
 	}
-	cluster := &v1alpha1.Cluster{}
+	cluster := &v1beta1.Cluster{}
 	if err := json.Unmarshal(jsonData, cluster); err != nil {
 		return nil, err
 	}
 	return cluster, nil
 }
 
 // GetClusterStatus return the given cluster status
-func (c *Client) GetClusterStatus(ctx context.Context, name, namespace string) (*v1alpha1.ClusterStatus, error) {
+func (c *Client) GetClusterStatus(ctx context.Context, name, namespace string) (*v1beta1.ClusterStatus, error) {
 	cluster, err := c.GetCluster(ctx, name, namespace)
 	if err != nil {
 		return nil, err

k8s/anthos/machines.go

@@ -3,15 +3,13 @@ package anthos
 import (
 	"context"
 	"encoding/json"
-
-	v1alpha1 "sigs.k8s.io/cluster-api/pkg/apis/deprecated/v1alpha1"
-
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime/schema"
+	v1beta1 "sigs.k8s.io/cluster-api/api/v1beta1"
 )
 
 var (
-	machineResource = schema.GroupVersionResource{Group: "cluster.k8s.io", Version: "v1alpha1", Resource: "machines"}
+	machineResource = schema.GroupVersionResource{Group: "cluster.k8s.io", Version: "v1beta1", Resource: "machines"}
 )
 
 const (
@@ -21,15 +19,15 @@ const (
 // MachinesOps is an interface to perform k8s machines operations
 type MachineOps interface {
 	// ListMachines lists all machines in kubernetes cluster
-	ListMachines(ctx context.Context) (*v1alpha1.MachineList, error)
+	ListMachines(ctx context.Context) (*v1beta1.MachineList, error)
 	// GetMachine returns a machine for the given name
-	GetMachine(ctx context.Context, name string) (*v1alpha1.Machine, error)
+	GetMachine(ctx context.Context, name string) (*v1beta1.Machine, error)
 	// DeleteMachine delete machine for given name
 	DeleteMachine(ctx context.Context, name string) error
 }
 
 // ListMachines lists all machines in kubernetes cluster
-func (c *Client) ListMachines(ctx context.Context) (*v1alpha1.MachineList, error) {
+func (c *Client) ListMachines(ctx context.Context) (*v1beta1.MachineList, error) {
 	if err := c.initClient(); err != nil {
 		return nil, err
 	}
@@ -42,7 +40,7 @@ func (c *Client) ListMachines(ctx context.Context) (*v1alpha1.MachineList, error
 	if err != nil {
 		return nil, err
 	}
-	machineList := &v1alpha1.MachineList{}
+	machineList := &v1beta1.MachineList{}
 	if err := json.Unmarshal(jsonData, machineList); err != nil {
 		return nil, err
 	}
@@ -51,7 +49,7 @@ func (c *Client) ListMachines(ctx context.Context) (*v1alpha1.MachineList, error
 }
 
 // GetMachine returns a machine for the given name
-func (c *Client) GetMachine(ctx context.Context, name string) (*v1alpha1.Machine, error) {
+func (c *Client) GetMachine(ctx context.Context, name string) (*v1beta1.Machine, error) {
 	if err := c.initClient(); err != nil {
 		return nil, err
 	}
@@ -63,7 +61,7 @@ func (c *Client) GetMachine(ctx context.Context, name string) (*v1alpha1.Machine
 	if err != nil {
 		return nil, err
 	}
-	machine := &v1alpha1.Machine{}
+	machine := &v1beta1.Machine{}
 	if err := json.Unmarshal(jsonData, machine); err != nil {
 		return nil, err
 	}