Rename IP states to Pending, Allocated

Author: damyan

api/ipam/v1alpha1/ip_types.go

@@ -9,9 +9,10 @@ import (
 )
 
 const (
-	FailedIPState     IPState = "Failed"
-	ProcessingIPState IPState = "Processing"
-	FinishedIPState   IPState = "Finished"
+	// TODO: Remove failed state
+	IPStateFailed    IPState = "Failed"
+	IPStatePending   IPState = "Pending"
+	IPStateAllocated IPState = "Allocated"
 )
 
 // IPState is a processing state of IP resource

internal/controller/ip_controller.go

@@ -109,13 +109,13 @@ func (r *IPReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Re
 		return ctrl.Result{}, err
 	}
 
-	if ip.Status.State == v1alpha1.FinishedIPState ||
-		ip.Status.State == v1alpha1.FailedIPState {
+	if ip.Status.State == v1alpha1.IPStateAllocated ||
+		ip.Status.State == v1alpha1.IPStateFailed {
 		return ctrl.Result{}, nil
 	}
 
 	if ip.Status.State == "" {
-		ip.Status.State = v1alpha1.ProcessingIPState
+		ip.Status.State = v1alpha1.IPStatePending
 		ip.Status.Message = ""
 		if err := r.Status().Update(ctx, ip); err != nil {
 			log.Error(err, "unable to update ip resource status", "name", req.NamespacedName, "currentStatus", ip.Status.State, "targetStatus", v1alpha1.CProcessingNetworkState)
@@ -140,7 +140,7 @@ func (r *IPReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Re
 	} else {
 		cidr, err := subnet.ProposeForCapacity(resource.NewScaledQuantity(1, 0))
 		if err != nil {
-			ip.Status.State = v1alpha1.FailedIPState
+			ip.Status.State = v1alpha1.IPStateFailed
 			ip.Status.Message = err.Error()
 			if err := r.Status().Update(ctx, ip); err != nil {
 				log.Error(err, "unable to update ip status", "name", req.NamespacedName)
@@ -152,7 +152,7 @@ func (r *IPReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Re
 	}
 
 	if err := subnet.Reserve(ipCidrToReserve); err != nil {
-		ip.Status.State = v1alpha1.FailedIPState
+		ip.Status.State = v1alpha1.IPStateFailed
 		ip.Status.Message = err.Error()
 		if err := r.Status().Update(ctx, ip); err != nil {
 			log.Error(err, "unable to update ip status", "name", req.NamespacedName)
@@ -167,7 +167,7 @@ func (r *IPReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Re
 		return ctrl.Result{}, err
 	}
 
-	ip.Status.State = v1alpha1.FinishedIPState
+	ip.Status.State = v1alpha1.IPStateAllocated
 	ip.Status.Message = ""
 	ip.Status.Reserved = ipCidrToReserve.AsIPAddr()
 	if err := r.Status().Update(ctx, ip); err != nil {

internal/controller/ip_controller_test.go

@@ -187,7 +187,7 @@ var _ = Describe("IP controller", func() {
 				if err != nil {
 					return false
 				}
-				if createdIP.Status.State != v1alpha1.FinishedIPState {
+				if createdIP.Status.State != v1alpha1.IPStateAllocated {
 					return false
 				}
 				return true
@@ -224,7 +224,7 @@ var _ = Describe("IP controller", func() {
 				if err != nil {
 					return false
 				}
-				if ipCopy.Status.State != v1alpha1.FailedIPState {
+				if ipCopy.Status.State != v1alpha1.IPStateFailed {
 					return false
 				}
 				return true
@@ -244,7 +244,7 @@ var _ = Describe("IP controller", func() {
 				if err != nil {
 					return false
 				}
-				if ipCopy.Status.State != v1alpha1.FinishedIPState {
+				if ipCopy.Status.State != v1alpha1.IPStateAllocated {
 					return false
 				}
 				if !ipCopy.Status.Reserved.Equal(testIP) {

internal/controller/subnet_controller.go

@@ -294,7 +294,7 @@ func (r *SubnetReconciler) SetupWithManager(mgr ctrl.Manager) error {
 		if parentSubnet == "" {
 			return nil
 		}
-		if state != v1alpha1.FailedIPState {
+		if state != v1alpha1.IPStateFailed {
 			return nil
 		}
 		return []string{parentSubnet}
@@ -432,7 +432,7 @@ func (r *SubnetReconciler) requeueFailedIPs(ctx context.Context, log logr.Logger
 	}
 
 	for _, ip := range ips.Items {
-		ip.Status.State = v1alpha1.ProcessingIPState
+		ip.Status.State = v1alpha1.IPStatePending
 		ip.Status.Message = ""
 		if err := r.Status().Update(ctx, &ip); err != nil {
 			log.Error(err, "unable to update child ips", "name", types.NamespacedName{Namespace: subnet.Namespace, Name: subnet.Name}, "subnet", subnet.Name)

internal/webhook/v1alpha1/subnet_webhook.go

@@ -60,7 +60,7 @@ func SetupSubnetWebhookWithManager(mgr ctrl.Manager) error {
 		}
 		state := ip.Status.State
 		parentSubnet := ip.Spec.Subnet.Name
-		if state != v1alpha1.FinishedIPState {
+		if state != v1alpha1.IPStateAllocated {
 			return nil
 		}
 		return []string{parentSubnet}

internal/webhook/v1alpha1/subnet_webhook_test.go

@@ -581,7 +581,7 @@ var _ = Describe("Subnet webhook", func() {
 				return err == nil
 			}, Timeout, Interval).Should(BeTrue())
 
-			childIP.Status.State = v1alpha1.FinishedIPState
+			childIP.Status.State = v1alpha1.IPStateAllocated
 			Expect(k8sClient.Status().Update(ctx, &childIP)).Should(Succeed())
 			Eventually(func() bool {
 				childIPsMatchingFields := client.MatchingFields{