blob: 9872e8bf84fa1e1cf57b6bfbe58ec0a4a02f2118 [file] [log] [blame]
From 243792d1686cba86669bda9bc2c905cb9cd73a0c Mon Sep 17 00:00:00 2001
From: Lorenz Brun <lorenz@monogon.tech>
Date: Wed, 4 May 2022 18:37:45 +0200
Subject: [PATCH] Adopt to renamed function in K8s 1.24
---
pkg/proxy/service.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/cmd/nfproxy.go b/cmd/nfproxy.go
index 66972ab..83d8b01 100644
--- a/cmd/nfproxy.go
+++ b/cmd/nfproxy.go
@@ -169,7 +169,7 @@ func main() {
// instantiate EndpointSlice controller, otherwise Endpoints controller will be used.
var ep epController
if endpointSlice {
- ep = controller.NewEndpointSliceController(nfproxy, client, kubeInformerFactory.Discovery().V1beta1().EndpointSlices())
+ ep = controller.NewEndpointSliceController(nfproxy, client, kubeInformerFactory.Discovery().V1().EndpointSlices())
} else {
ep = controller.NewEndpointsController(nfproxy, client, kubeInformerFactory.Core().V1().Endpoints())
}
diff --git a/pkg/controller/controller_endpointslice.go b/pkg/controller/controller_endpointslice.go
index ef97ef5..d060a4d 100644
--- a/pkg/controller/controller_endpointslice.go
+++ b/pkg/controller/controller_endpointslice.go
@@ -20,9 +20,9 @@ import (
"fmt"
v1 "k8s.io/api/core/v1"
- discovery "k8s.io/api/discovery/v1beta1"
+ discovery "k8s.io/api/discovery/v1"
utilruntime "k8s.io/apimachinery/pkg/util/runtime"
- "k8s.io/client-go/informers/discovery/v1beta1"
+ discoveryv1 "k8s.io/client-go/informers/discovery/v1"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/kubernetes/scheme"
typedcorev1 "k8s.io/client-go/kubernetes/typed/core/v1"
@@ -119,7 +119,7 @@ func (c *endpointSliceController) Start(stopCh <-chan struct{}) error {
func NewEndpointSliceController(
proxy proxy.Proxy,
kubeClientset kubernetes.Interface,
- epSliceInformer v1beta1.EndpointSliceInformer) EndpointSliceController {
+ epSliceInformer discoveryv1.EndpointSliceInformer) EndpointSliceController {
klog.V(4).Info("Creating event broadcaster for EndpointSlice controller")
eventBroadcaster := record.NewBroadcaster()
diff --git a/pkg/proxy/cache.go b/pkg/proxy/cache.go
index 92d06ca..7ef0e6f 100644
--- a/pkg/proxy/cache.go
+++ b/pkg/proxy/cache.go
@@ -21,7 +21,7 @@ import (
"sync"
v1 "k8s.io/api/core/v1"
- discovery "k8s.io/api/discovery/v1beta1"
+ discovery "k8s.io/api/discovery/v1"
"k8s.io/apimachinery/pkg/types"
"k8s.io/klog"
)
diff --git a/pkg/proxy/proxy.go b/pkg/proxy/proxy.go
index 7839820..5876784 100644
--- a/pkg/proxy/proxy.go
+++ b/pkg/proxy/proxy.go
@@ -22,7 +22,7 @@ import (
utilnftables "github.com/google/nftables"
"github.com/sbezverk/nfproxy/pkg/nftables"
v1 "k8s.io/api/core/v1"
- discovery "k8s.io/api/discovery/v1beta1"
+ discovery "k8s.io/api/discovery/v1"
"k8s.io/apimachinery/pkg/types"
"k8s.io/client-go/tools/record"
"k8s.io/klog"
diff --git a/pkg/proxy/proxy_endpointslice.go b/pkg/proxy/proxy_endpointslice.go
index 5310ed3..5c97096 100644
--- a/pkg/proxy/proxy_endpointslice.go
+++ b/pkg/proxy/proxy_endpointslice.go
@@ -21,7 +21,7 @@ import (
"time"
v1 "k8s.io/api/core/v1"
- discovery "k8s.io/api/discovery/v1beta1"
+ discovery "k8s.io/api/discovery/v1"
"k8s.io/klog"
)
diff --git a/pkg/proxy/service.go b/pkg/proxy/service.go
index 9cc10b7..6e91fae 100644
--- a/pkg/proxy/service.go
+++ b/pkg/proxy/service.go
@@ -152,7 +152,7 @@ func newServiceInfo(port *v1.ServicePort, service *v1.Service, baseInfo *BaseSer
func newBaseServiceInfo(port *v1.ServicePort, service *v1.Service) *BaseServiceInfo {
onlyNodeLocalEndpoints := false
- if apiservice.RequestsOnlyLocalTraffic(service) {
+ if apiservice.ExternalPolicyLocal(service) {
onlyNodeLocalEndpoints = true
}
var stickyMaxAgeSeconds int
diff --git a/pkg/proxy/tools.go b/pkg/proxy/tools.go
index 06c4ae3..3f7f0b9 100644
--- a/pkg/proxy/tools.go
+++ b/pkg/proxy/tools.go
@@ -26,7 +26,7 @@ import (
utilnftables "github.com/google/nftables"
v1 "k8s.io/api/core/v1"
- discovery "k8s.io/api/discovery/v1beta1"
+ discovery "k8s.io/api/discovery/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/types"
"k8s.io/apimachinery/pkg/util/intstr"
--
2.25.1