Adopt v1beta2 conditions for IBM VPC cluster

Author: Amulyam24

api/v1beta1/zz_generated.conversion.go

@@ -198,6 +198,23 @@ const (
 	IBMPowerVSClusterReadyUnknownV1Beta2Reason = clusterv1beta1.ReadyUnknownV1Beta2Reason
 )
 
+// IBMVPCCluster's Ready condition and corresponding reasons that will be used in v1Beta2 API version.
+const (
+	// IBMVPCClusterReadyV1Beta2Condition is true if the IBMVPCCluster's deletionTimestamp is not set and IBMVPCCluster's
+	// conditions are true.
+	IBMVPCClusterReadyV1Beta2Condition = clusterv1beta1.ReadyV1Beta2Condition
+
+	// IBMVPCClusterReadyV1Beta2Reason surfaces when the IBMVPCCluster readiness criteria is met.
+	IBMVPCClusterReadyV1Beta2Reason = clusterv1beta1.ReadyV1Beta2Reason
+
+	// IBMVPCClusterNotReadyV1Beta2Reason surfaces when the IBMVPCCluster readiness criteria is not met.
+	IBMVPCClusterNotReadyV1Beta2Reason = clusterv1beta1.NotReadyV1Beta2Reason
+
+	// IBMVPCClusterReadyUnknownV1Beta2Reason surfaces when at least one of the IBMVPCCluster readiness criteria is unknown
+	// and none of the IBMVPCCluster readiness criteria is met.
+	IBMVPCClusterReadyUnknownV1Beta2Reason = clusterv1beta1.ReadyUnknownV1Beta2Reason
+)
+
 const (
 	// WorkspaceReadyV1Beta2Condition reports on the successful reconciliation of a PowerVS workspace.
 	WorkspaceReadyV1Beta2Condition = "WorkspaceReady"
@@ -283,6 +300,15 @@ const (
 	// VPCLoadBalancerDeletingV1Beta2Reason surfaces when the VPC LoadBalancer is being deleted.
 	VPCLoadBalancerDeletingV1Beta2Reason = clusterv1beta1.DeletingV1Beta2Reason
 
+	// VPCImageReadyV1Beta2Condition reports on the successful reconciliation of a VPC custom image.
+	VPCImageReadyV1Beta2Condition = "VPCImageReady"
+
+	// VPCImageReadyV1Beta2Reason surfaces when the VPC custom image is ready.
+	VPCImageReadyV1Beta2Reason = clusterv1beta1.ReadyV1Beta2Reason
+
+	// VPCImageReadyV1Beta2Reason surfaces when the VPC custom image is not ready.
+	VPCImageNotReadyV1Beta2Reason = clusterv1beta1.NotReadyV1Beta2Reason
+
 	// COSInstanceReadyV1Beta2Condition reports on the successful reconciliation of a COS instance.
 	COSInstanceReadyV1Beta2Condition = "COSInstanceReady"
 

api/v1beta2/conditions_consts.go

@@ -320,6 +320,22 @@ type IBMVPCClusterStatus struct {
 	// Conditions defines current service state of the load balancer.
 	// +optional
 	Conditions clusterv1beta1.Conditions `json:"conditions,omitempty"`
+
+	// V1beta2 groups all the fields that will be added or modified in IBMVPCCluster's status with the V1Beta2 version.
+	// +optional
+	V1Beta2 *IBMVPCClusterV1Beta2Status `json:"v1beta2,omitempty"`
+}
+
+// IBMVPCClusterV1Beta2Status groups all the fields that will be added or modified in IBMVPCClusterStatus with the V1Beta2 version.
+// See https://github.com/kubernetes-sigs/cluster-api/blob/main/docs/proposals/20240916-improve-status-in-CAPI-resources.md for more context.
+type IBMVPCClusterV1Beta2Status struct {
+	// Conditions represents the observations of a IBMVPCCluster's current state.
+	// Known condition types are Ready, NotReady and Paused.
+	// +optional
+	// +listType=map
+	// +listMapKey=type
+	// +kubebuilder:validation:MaxItems=32
+	Conditions []metav1.Condition `json:"conditions,omitempty"`
 }
 
 // VPCNetworkStatus provides details on the status of VPC network resources for extended VPC Infrastructure support.
@@ -400,6 +416,22 @@ func (r *IBMVPCCluster) SetConditions(conditions clusterv1beta1.Conditions) {
 	r.Status.Conditions = conditions
 }
 
+// GetV1Beta2Conditions returns the set of conditions for IBMVPCCluster object.
+func (r *IBMVPCCluster) GetV1Beta2Conditions() []metav1.Condition {
+	if r.Status.V1Beta2 == nil {
+		return nil
+	}
+	return r.Status.V1Beta2.Conditions
+}
+
+// SetV1Beta2Conditions sets conditions for IBMVPCCluster object.
+func (r *IBMVPCCluster) SetV1Beta2Conditions(conditions []metav1.Condition) {
+	if r.Status.V1Beta2 == nil {
+		r.Status.V1Beta2 = &IBMVPCClusterV1Beta2Status{}
+	}
+	r.Status.V1Beta2.Conditions = conditions
+}
+
 func init() {
 	objectTypes = append(objectTypes, &IBMVPCCluster{}, &IBMVPCClusterList{})
 }

api/v1beta2/ibmvpccluster_types.go

@@ -28,6 +28,7 @@ import (
 
 	"k8s.io/klog/v2"
 
+	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 
 	clusterv1 "sigs.k8s.io/cluster-api/api/core/v1beta2"
@@ -105,7 +106,7 @@ func NewClusterScope(params ClusterScopeParams) (*ClusterScope, error) {
 }
 
 // CreateVPC creates a new IBM VPC in specified resource group.
-func (s *ClusterScope) CreateVPC() (*vpcv1.VPC, error) {
+func (s *ClusterScope) CreateVPC(ctx context.Context) (*vpcv1.VPC, error) {
 	vpcReply, err := s.ensureVPCUnique(s.IBMVPCCluster.Spec.VPC)
 	if err != nil {
 		return nil, err
@@ -132,7 +133,7 @@ func (s *ClusterScope) CreateVPC() (*vpcv1.VPC, error) {
 }
 
 // DeleteVPC deletes IBM VPC associated with a VPC id.
-func (s *ClusterScope) DeleteVPC() error {
+func (s *ClusterScope) DeleteVPC(ctx context.Context) error {
 	if s.IBMVPCCluster.Status.VPC.ID == "" {
 		return nil
 	}
@@ -205,7 +206,7 @@ func (s *ClusterScope) updateDefaultSG(sgID string) error {
 }
 
 // CreateSubnet creates a subnet within provided vpc and zone.
-func (s *ClusterScope) CreateSubnet() (*vpcv1.Subnet, error) {
+func (s *ClusterScope) CreateSubnet(ctx context.Context) (*vpcv1.Subnet, error) {
 	subnetName := s.IBMVPCCluster.Name + subnetSuffix
 	subnetReply, err := s.ensureSubnetUnique(subnetName)
 	if err != nil {
@@ -334,7 +335,8 @@ func (s *ClusterScope) ensureSubnetUnique(subnetName string) (*vpcv1.Subnet, err
 }
 
 // DeleteSubnet deletes a subnet associated with subnet id.
-func (s *ClusterScope) DeleteSubnet() error {
+func (s *ClusterScope) DeleteSubnet(ctx context.Context) error {
+	log := ctrl.LoggerFrom(ctx)
 	if s.IBMVPCCluster.Status.Subnet.ID == nil {
 		return nil
 	}
@@ -377,7 +379,7 @@ func (s *ClusterScope) DeleteSubnet() error {
 	}
 
 	if !found {
-		s.Logger.V(3).Info("No subnets found with ID", "Subnet ID", subnetID)
+		log.V(3).Info("No subnets found with ID", "Subnet ID", subnetID)
 		return nil
 	}
 
@@ -460,7 +462,7 @@ func (s *ClusterScope) detachPublicGateway(subnetID string, pgwID string) error
 }
 
 // CreateLoadBalancer creates a new IBM VPC load balancer in specified resource group.
-func (s *ClusterScope) CreateLoadBalancer() (*vpcv1.LoadBalancer, error) {
+func (s *ClusterScope) CreateLoadBalancer(ctx context.Context) (*vpcv1.LoadBalancer, error) {
 	loadBalancerReply, err := s.ensureLoadBalancerUnique(s.IBMVPCCluster.Spec.ControlPlaneLoadBalancer.Name)
 	if err != nil {
 		return nil, err
@@ -600,7 +602,7 @@ func (s *ClusterScope) ensureLoadBalancerUnique(loadBalancerName string) (*vpcv1
 }
 
 // DeleteLoadBalancer deletes IBM VPC load balancer associated with a VPC id.
-func (s *ClusterScope) DeleteLoadBalancer() (bool, error) {
+func (s *ClusterScope) DeleteLoadBalancer(ctx context.Context) (bool, error) {
 	deleted := false
 	if lbipID := s.GetLoadBalancerID(); lbipID != "" {
 		f := func(start string) (bool, string, error) {