Stop serving v1alpha3 API types

Signed-off-by: killianmuldoon <[email protected]>

api/v1alpha3/cluster_types.go

@@ -200,6 +200,7 @@ func (v APIEndpoint) String() string {
 // ANCHOR_END: APIEndpoint
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 // +kubebuilder:resource:path=clusters,shortName=cl,scope=Namespaced,categories=cluster-api
 // +kubebuilder:subresource:status
 // +kubebuilder:printcolumn:name="Phase",type="string",JSONPath=".status.phase",description="Cluster status such as Pending/Provisioning/Provisioned/Deleting/Failed"
@@ -224,6 +225,7 @@ func (c *Cluster) SetConditions(conditions Conditions) {
 }
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 
 // ClusterList contains a list of Cluster.
 type ClusterList struct {

api/v1alpha3/doc.go

@@ -18,4 +18,5 @@ limitations under the License.
 // +k8s:conversion-gen=sigs.k8s.io/cluster-api/api/v1beta1
 //
 // Deprecated: This package will be removed in one of the next releases.
+// +kubebuilder:unservedversion
 package v1alpha3

api/v1alpha3/machine_types.go

@@ -237,6 +237,7 @@ type Bootstrap struct {
 // ANCHOR_END: Bootstrap
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 // +kubebuilder:resource:path=machines,shortName=ma,scope=Namespaced,categories=cluster-api
 // +kubebuilder:subresource:status
 // +kubebuilder:printcolumn:name="ProviderID",type="string",JSONPath=".spec.providerID",description="Provider ID"
@@ -266,6 +267,7 @@ func (m *Machine) SetConditions(conditions Conditions) {
 }
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 
 // MachineList contains a list of Machine.
 //

api/v1alpha3/machinedeployment_types.go

@@ -241,6 +241,7 @@ func (md *MachineDeploymentStatus) GetTypedPhase() MachineDeploymentPhase {
 }
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 // +kubebuilder:resource:path=machinedeployments,shortName=md,scope=Namespaced,categories=cluster-api
 // +kubebuilder:subresource:status
 // +kubebuilder:subresource:scale:specpath=.spec.replicas,statuspath=.status.replicas,selectorpath=.status.selector
@@ -262,6 +263,7 @@ type MachineDeployment struct {
 }
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 
 // MachineDeploymentList contains a list of MachineDeployment.
 //

api/v1alpha3/machinehealthcheck_types.go

@@ -114,6 +114,7 @@ type MachineHealthCheckStatus struct {
 // ANCHOR_END: MachineHealthCheckStatus
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 // +kubebuilder:resource:path=machinehealthchecks,shortName=mhc;mhcs,scope=Namespaced,categories=cluster-api
 // +kubebuilder:subresource:status
 // +kubebuilder:printcolumn:name="MaxUnhealthy",type="string",JSONPath=".spec.maxUnhealthy",description="Maximum number of unhealthy machines allowed"
@@ -145,6 +146,7 @@ func (m *MachineHealthCheck) SetConditions(conditions Conditions) {
 }
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 
 // MachineHealthCheckList contains a list of MachineHealthCheck.
 //

api/v1alpha3/machineset_types.go

@@ -185,6 +185,7 @@ func (m *MachineSet) Validate() field.ErrorList {
 }
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 // +kubebuilder:resource:path=machinesets,shortName=ms,scope=Namespaced,categories=cluster-api
 // +kubebuilder:subresource:status
 // +kubebuilder:subresource:scale:specpath=.spec.replicas,statuspath=.status.replicas,selectorpath=.status.selector
@@ -204,6 +205,7 @@ type MachineSet struct {
 }
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 
 // MachineSetList contains a list of MachineSet.
 //

api/v1alpha3/webhook_test.go

@@ -30,6 +30,8 @@ import (
 )
 
 func TestClusterConversion(t *testing.T) {
+	t.Skipf("v1alpha3 is no longer served see: https://cluster-api.sigs.k8s.io/contributing#removal-of-v1alpha3--v1alpha4-apiversions")
+
 	g := NewWithT(t)
 	ns, err := env.CreateNamespace(ctx, fmt.Sprintf("conversion-webhook-%s", util.RandomString(5)))
 	g.Expect(err).ToNot(HaveOccurred())
@@ -48,6 +50,7 @@ func TestClusterConversion(t *testing.T) {
 }
 
 func TestMachineSetConversion(t *testing.T) {
+	t.Skipf("v1alpha3 is no longer served see: https://cluster-api.sigs.k8s.io/contributing#removal-of-v1alpha3--v1alpha4-apiversions")
 	g := NewWithT(t)
 	ns, err := env.CreateNamespace(ctx, fmt.Sprintf("conversion-webhook-%s", util.RandomString(5)))
 	g.Expect(err).ToNot(HaveOccurred())
@@ -75,6 +78,7 @@ func TestMachineSetConversion(t *testing.T) {
 }
 
 func TestMachineDeploymentConversion(t *testing.T) {
+	t.Skipf("v1alpha3 is no longer served see: https://cluster-api.sigs.k8s.io/contributing#removal-of-v1alpha3--v1alpha4-apiversions")
 	g := NewWithT(t)
 	ns, err := env.CreateNamespace(ctx, fmt.Sprintf("conversion-webhook-%s", util.RandomString(5)))
 	g.Expect(err).ToNot(HaveOccurred())

bootstrap/kubeadm/api/v1alpha3/kubeadmconfig_types.go

@@ -132,6 +132,7 @@ type KubeadmConfigStatus struct {
 }
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 // +kubebuilder:resource:path=kubeadmconfigs,scope=Namespaced,categories=cluster-api
 // +kubebuilder:subresource:status
 
@@ -157,6 +158,7 @@ func (c *KubeadmConfig) SetConditions(conditions clusterv1alpha3.Conditions) {
 }
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 
 // KubeadmConfigList contains a list of KubeadmConfig.
 //

bootstrap/kubeadm/api/v1alpha3/kubeadmconfigtemplate_types.go

@@ -31,6 +31,7 @@ type KubeadmConfigTemplateResource struct {
 }
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 // +kubebuilder:resource:path=kubeadmconfigtemplates,scope=Namespaced,categories=cluster-api
 
 // KubeadmConfigTemplate is the Schema for the kubeadmconfigtemplates API.
@@ -44,6 +45,7 @@ type KubeadmConfigTemplate struct {
 }
 
 // +kubebuilder:object:root=true
+// +kubebuilder:unservedversion
 
 // KubeadmConfigTemplateList contains a list of KubeadmConfigTemplate.
 //

bootstrap/kubeadm/api/v1alpha3/webhook_test.go

@@ -30,6 +30,7 @@ import (
 )
 
 func TestKubeadmConfigConversion(t *testing.T) {
+	t.Skipf("v1alpha3 is no longer served see: https://cluster-api.sigs.k8s.io/contributing#removal-of-v1alpha3--v1alpha4-apiversions")
 	g := NewWithT(t)
 	ns, err := env.CreateNamespace(ctx, fmt.Sprintf("conversion-webhook-%s", util.RandomString(5)))
 	g.Expect(err).ToNot(HaveOccurred())
@@ -49,6 +50,7 @@ func TestKubeadmConfigConversion(t *testing.T) {
 }
 
 func TestKubeadmConfigTemplateConversion(t *testing.T) {
+	t.Skipf("v1alpha3 is no longer served see: https://cluster-api.sigs.k8s.io/contributing#removal-of-v1alpha3--v1alpha4-apiversions")
 	g := NewWithT(t)
 	ns, err := env.CreateNamespace(ctx, fmt.Sprintf("conversion-webhook-%s", util.RandomString(5)))
 	g.Expect(err).ToNot(HaveOccurred())

cmd/clusterctl/client/cluster/crd_migration.go

@@ -71,15 +71,19 @@ func (m *crdMigrator) Run(ctx context.Context, objs []unstructured.Unstructured)
 }
 
 // run migrates CRs of a new CRD.
-// This is necessary when the new CRD drops a version which
-// was previously used as a storage version.
+// This is necessary when the new CRD drops or stops serving
+// a version which was previously used as a storage version.
 func (m *crdMigrator) run(ctx context.Context, newCRD *apiextensionsv1.CustomResourceDefinition) (bool, error) {
 	log := logf.Log
 
-	// Gets the list of version supported by the new CRD
+	// Gets the list of versions supported by the new CRD and a list of versions served on the CRD.
 	newVersions := sets.Set[string]{}
+	servedVersions := sets.Set[string]{}
 	for _, version := range newCRD.Spec.Versions {
 		newVersions.Insert(version.Name)
+		if version.Served {
+			servedVersions.Insert(version.Name)
+		}
 	}
 
 	// Get the current CRD.
@@ -106,10 +110,9 @@ func (m *crdMigrator) run(ctx context.Context, newCRD *apiextensionsv1.CustomRes
 	}
 
 	currentStatusStoredVersions := sets.Set[string]{}.Insert(currentCRD.Status.StoredVersions...)
-
 	// If the new CRD still contains all current stored versions, nothing to do
 	// as no previous storage version will be dropped.
-	if newVersions.HasAll(currentStatusStoredVersions.UnsortedList()...) {
+	if servedVersions.HasAll(currentStatusStoredVersions.UnsortedList()...) {
 		log.V(2).Info("CRD migration check passed", "name", newCRD.Name)
 		return false, nil
 	}
@@ -121,8 +124,8 @@ func (m *crdMigrator) run(ctx context.Context, newCRD *apiextensionsv1.CustomRes
 	// This way we can make sure that all CR objects are now stored in the current storage version.
 	// Alternatively, we would have to figure out which objects are stored in which version but this information is not
 	// exposed by the apiserver.
-	storedVersionsToDelete := currentStatusStoredVersions.Difference(newVersions)
-	storedVersionsToPreserve := currentStatusStoredVersions.Intersection(newVersions)
+	storedVersionsToDelete := currentStatusStoredVersions.Difference(servedVersions)
+	storedVersionsToPreserve := currentStatusStoredVersions.Intersection(servedVersions)
 	log.Info("CR migration required", "kind", newCRD.Spec.Names.Kind, "storedVersionsToDelete", strings.Join(sets.List(storedVersionsToDelete), ","), "storedVersionsToPreserve", strings.Join(sets.List(storedVersionsToPreserve), ","))
 
 	if err := m.migrateResourcesForCRD(ctx, currentCRD, currentStorageVersion); err != nil {
@@ -136,6 +139,16 @@ func (m *crdMigrator) run(ctx context.Context, newCRD *apiextensionsv1.CustomRes
 	return true, nil
 }
 
+func getStatusServedStoredVersions(currentCRD *apiextensionsv1.CustomResourceDefinition, servedVersions sets.Set[string]) sets.Set[string] {
+	out := sets.Set[string]{}
+	for _, version := range currentCRD.Status.StoredVersions {
+		if servedVersions.Has(version) {
+			out.Insert(version)
+		}
+	}
+	return out
+}
+
 func (m *crdMigrator) migrateResourcesForCRD(ctx context.Context, crd *apiextensionsv1.CustomResourceDefinition, currentStorageVersion string) error {
 	log := logf.Log
 	log.Info("Migrating CRs, this operation may take a while...", "kind", crd.Spec.Names.Kind)