Fixes pause of IPAddressClaim

pkg/kubernetes/ipam/ipam.go

@@ -200,15 +200,15 @@ func (h *Helper) CreateIPAddressClaim(ctx context.Context, owner client.Object,
 
 	// Ensures that the claim has a reference to the cluster of the VM to
 	// support pausing reconciliation.
-	annotations := map[string]string{
-		clusterv1.ClusterNameAnnotation: h.cluster.GetName(),
+	labels := map[string]string{
+		clusterv1.ClusterNameLabel: h.cluster.GetName(),
 	}
 
 	desired := &ipamv1.IPAddressClaim{
 		ObjectMeta: metav1.ObjectMeta{
-			Name:        fmt.Sprintf("%s-%s-%s", owner.GetName(), device, suffix),
-			Namespace:   owner.GetNamespace(),
-			Annotations: annotations,
+			Name:      fmt.Sprintf("%s-%s-%s", owner.GetName(), device, suffix),
+			Namespace: owner.GetNamespace(),
+			Labels:    labels,
 		},
 		Spec: ipamv1.IPAddressClaimSpec{
 			PoolRef: corev1.TypedLocalObjectReference{

pkg/kubernetes/ipam/ipam_test.go

@@ -18,6 +18,7 @@ package ipam
 
 import (
 	"context"
+	"fmt"
 	"testing"
 
 	"github.com/stretchr/testify/require"
@@ -237,6 +238,15 @@ func (s *IPAMTestSuite) Test_CreateIPAddressClaim() {
 	err := s.helper.CreateIPAddressClaim(s.ctx, getCluster(), device, infrav1.IPV4Format, nil)
 	s.NoError(err)
 
+	// Ensure cluster label is set.
+	var claim ipamv1.IPAddressClaim
+	name := fmt.Sprintf("%s-%s-%s", getCluster().GetName(), device, infrav1.DefaultSuffix)
+	nn := types.NamespacedName{Name: name, Namespace: getCluster().GetNamespace()}
+	err = s.cl.Get(s.ctx, nn, &claim)
+	s.NoError(err)
+	s.Contains(claim.ObjectMeta.Labels, clusterv1.ClusterNameLabel)
+	s.Equal(getCluster().GetName(), claim.ObjectMeta.Labels[clusterv1.ClusterNameLabel])
+
 	// additional device with InClusterIPPool
 	s.NoError(s.helper.ctrlClient.Create(s.ctx, &ipamicv1.InClusterIPPool{
 		ObjectMeta: metav1.ObjectMeta{