modify components to use the networking v1beta1 API

Author: aojea

cmd/kube-apiserver/app/aggregator.go

@@ -40,6 +40,7 @@ var apiVersionPriorities = merge(controlplaneapiserver.DefaultGenericAPIServiceP
 	{Group: "batch", Version: "v1beta1"}:              {Group: 17400, Version: 9},
 	{Group: "batch", Version: "v2alpha1"}:             {Group: 17400, Version: 9},
 	{Group: "networking.k8s.io", Version: "v1"}:       {Group: 17200, Version: 15},
+	{Group: "networking.k8s.io", Version: "v1beta1"}:  {Group: 17200, Version: 9},
 	{Group: "networking.k8s.io", Version: "v1alpha1"}: {Group: 17200, Version: 1},
 	{Group: "policy", Version: "v1"}:                  {Group: 17100, Version: 15},
 	{Group: "policy", Version: "v1beta1"}:             {Group: 17100, Version: 9},

cmd/kube-controller-manager/app/networking.go

@@ -40,8 +40,8 @@ func newServiceCIDRsControllerDescriptor() *ControllerDescriptor {
 func startServiceCIDRsController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) {
 	go servicecidrs.NewController(
 		ctx,
-		controllerContext.InformerFactory.Networking().V1alpha1().ServiceCIDRs(),
-		controllerContext.InformerFactory.Networking().V1alpha1().IPAddresses(),
+		controllerContext.InformerFactory.Networking().V1beta1().ServiceCIDRs(),
+		controllerContext.InformerFactory.Networking().V1beta1().IPAddresses(),
 		controllerContext.ClientBuilder.ClientOrDie("service-cidrs-controller"),
 	).Run(ctx, 5)
 	// TODO use component config

cmd/kube-proxy/app/server.go

@@ -982,7 +982,7 @@ func (s *ProxyServer) Run(ctx context.Context) error {
 	go endpointSliceConfig.Run(ctx.Done())
 
 	if utilfeature.DefaultFeatureGate.Enabled(features.MultiCIDRServiceAllocator) {
-		serviceCIDRConfig := config.NewServiceCIDRConfig(ctx, informerFactory.Networking().V1alpha1().ServiceCIDRs(), s.Config.ConfigSyncPeriod.Duration)
+		serviceCIDRConfig := config.NewServiceCIDRConfig(ctx, informerFactory.Networking().V1beta1().ServiceCIDRs(), s.Config.ConfigSyncPeriod.Duration)
 		serviceCIDRConfig.RegisterEventHandler(s.Proxier)
 		go serviceCIDRConfig.Run(wait.NeverStop)
 	}

pkg/api/servicecidr/servicecidr.go

@@ -21,14 +21,14 @@ import (
 	"net"
 	"net/netip"
 
-	networkingv1alpha1 "k8s.io/api/networking/v1alpha1"
+	networkingv1beta1 "k8s.io/api/networking/v1beta1"
 	"k8s.io/apimachinery/pkg/labels"
-	networkinglisters "k8s.io/client-go/listers/networking/v1alpha1"
+	networkinglisters "k8s.io/client-go/listers/networking/v1beta1"
 )
 
 // OverlapsPrefix return the list of ServiceCIDR that overlaps with the prefix passed as argument
-func OverlapsPrefix(serviceCIDRLister networkinglisters.ServiceCIDRLister, prefix netip.Prefix) []*networkingv1alpha1.ServiceCIDR {
-	result := []*networkingv1alpha1.ServiceCIDR{}
+func OverlapsPrefix(serviceCIDRLister networkinglisters.ServiceCIDRLister, prefix netip.Prefix) []*networkingv1beta1.ServiceCIDR {
+	result := []*networkingv1beta1.ServiceCIDR{}
 	serviceCIDRList, err := serviceCIDRLister.List(labels.Everything())
 	if err != nil {
 		return result
@@ -47,8 +47,8 @@ func OverlapsPrefix(serviceCIDRLister networkinglisters.ServiceCIDRLister, prefi
 }
 
 // ContainsPrefix return the list of ServiceCIDR that contains the prefix passed as argument
-func ContainsPrefix(serviceCIDRLister networkinglisters.ServiceCIDRLister, prefix netip.Prefix) []*networkingv1alpha1.ServiceCIDR {
-	result := []*networkingv1alpha1.ServiceCIDR{}
+func ContainsPrefix(serviceCIDRLister networkinglisters.ServiceCIDRLister, prefix netip.Prefix) []*networkingv1beta1.ServiceCIDR {
+	result := []*networkingv1beta1.ServiceCIDR{}
 	serviceCIDRList, err := serviceCIDRLister.List(labels.Everything())
 	if err != nil {
 		return result
@@ -67,14 +67,14 @@ func ContainsPrefix(serviceCIDRLister networkinglisters.ServiceCIDRLister, prefi
 }
 
 // ContainsIP return the list of ServiceCIDR that contains the IP address passed as argument
-func ContainsIP(serviceCIDRLister networkinglisters.ServiceCIDRLister, ip net.IP) []*networkingv1alpha1.ServiceCIDR {
+func ContainsIP(serviceCIDRLister networkinglisters.ServiceCIDRLister, ip net.IP) []*networkingv1beta1.ServiceCIDR {
 	address := IPToAddr(ip)
 	return ContainsAddress(serviceCIDRLister, address)
 }
 
 // ContainsAddress return the list of ServiceCIDR that contains the address passed as argument
-func ContainsAddress(serviceCIDRLister networkinglisters.ServiceCIDRLister, address netip.Addr) []*networkingv1alpha1.ServiceCIDR {
-	result := []*networkingv1alpha1.ServiceCIDR{}
+func ContainsAddress(serviceCIDRLister networkinglisters.ServiceCIDRLister, address netip.Addr) []*networkingv1beta1.ServiceCIDR {
+	result := []*networkingv1beta1.ServiceCIDR{}
 	serviceCIDRList, err := serviceCIDRLister.List(labels.Everything())
 	if err != nil {
 		return result