Adding GCPMachinePool Functionality

cloud/const.go

@@ -0,0 +1,28 @@
+/*
+Copyright 2023 The Kubernetes Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+	http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package cloud
+
+const (
+	// CustomDataHashAnnotation is the key for the machine object annotation
+	// which tracks the hash of the custom data.
+	// See https://kubernetes.io/docs/concepts/overview/working-with-objects/annotations/
+	// for annotation formatting rules.
+	CustomDataHashAnnotation = "sigs.k8s.io/cluster-api-provider-gcp-mig-custom-data-hash"
+
+	// ClusterAPIImagePrefix is the prefix for the image name used by the Cluster API provider for GCP.
+	ClusterAPIImagePrefix = "capi-ubuntu-1804-k8s-"
+)

cloud/gcperrors/errors.go

@@ -19,6 +19,7 @@ package gcperrors
 
 import (
 	"net/http"
+	"strings"
 
 	"google.golang.org/api/googleapi"
 )
@@ -43,3 +44,32 @@ func IgnoreNotFound(err error) error {
 
 	return err
 }
+
+// IsAlreadyDeleted reports whether err is a Google API error indicating that the resource is already being deleted.
+func IsAlreadyDeleted(err error) bool {
+	if err == nil {
+		return false
+	}
+	ae, _ := err.(*googleapi.Error)
+
+	return strings.Contains(ae.Errors[0].Message, "Instance is already being deleted.")
+}
+
+// IsMemberNotFound reports whether err is a Google API error indicating that the member is not found.
+func IsMemberNotFound(err error) bool {
+	if err == nil {
+		return false
+	}
+	ae, _ := err.(*googleapi.Error)
+
+	return strings.Contains(ae.Errors[0].Message, "is not a member of")
+}
+
+// PrintGCPError returns the error message from a Google API error.
+func PrintGCPError(err error) string {
+	if err == nil {
+		return ""
+	}
+	ae, _ := err.(*googleapi.Error)
+	return ae.Message + " " + ae.Errors[0].Message + " " + ae.Errors[0].Reason
+}

cloud/interfaces.go

@@ -105,3 +105,13 @@ type Machine interface {
 	MachineGetter
 	MachineSetter
 }
+
+// MachinePoolGetter is an interface which can get machine pool information.
+type MachinePoolGetter interface {
+	Project() string
+}
+
+// MachinePool is an interface which can get machine pool information.
+type MachinePool interface {
+	MachinePoolGetter
+}

cloud/scope/machine.go

@@ -222,7 +222,7 @@ func (m *MachineScope) InstanceImageSpec() *compute.AttachedDisk {
 	if m.Machine.Spec.Version != nil {
 		version = *m.Machine.Spec.Version
 	}
-	image := "capi-ubuntu-1804-k8s-" + strings.ReplaceAll(semver.MajorMinor(version), ".", "-")
+	image := cloud.ClusterAPIImagePrefix + strings.ReplaceAll(semver.MajorMinor(version), ".", "-")
 	sourceImage := path.Join("projects", m.ClusterGetter.Project(), "global", "images", "family", image)
 	if m.GCPMachine.Spec.Image != nil {
 		sourceImage = *m.GCPMachine.Spec.Image