[Windows] Enable EndpointSlices support on Antrea windows (#3321)

* Enable endpointslices feature in antrea-windows.yml * Make some endpointslices logs more accurate Signed-off-by: Shuyang Xin <[email protected]>
antrea-io · Feb 28, 2022 · 0d048e7 · 0d048e7
1 parent 57ef15c
commit 0d048e7
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 5 deletions.
diff --git a/build/yamls/antrea-windows.yml b/build/yamls/antrea-windows.yml
@@ -23,6 +23,11 @@ data:
     # Service traffic.
     #  AntreaProxy: true
 
+    # Enable EndpointSlice support in AntreaProxy. Don't enable this feature unless that EndpointSlice
+    # API version v1beta1 is supported and set as enabled in Kubernetes. If AntreaProxy is not enabled,
+    # this flag will not take effect.
+    #  EndpointSlice: false
+
     # Enable flowexporter which exports polled conntrack connections as IPFIX flow records from each agent to a configured collector.
     #  FlowExporter: false
 
@@ -144,7 +149,7 @@ kind: ConfigMap
 metadata:
   labels:
     app: antrea
-  name: antrea-windows-config-25k48fh55f
+  name: antrea-windows-config-mf82kffb45
   namespace: kube-system
 ---
 apiVersion: apps/v1
@@ -232,7 +237,7 @@ spec:
         operator: Exists
       volumes:
       - configMap:
-          name: antrea-windows-config-25k48fh55f
+          name: antrea-windows-config-mf82kffb45
         name: antrea-windows-config
       - configMap:
           defaultMode: 420

diff --git a/build/yamls/windows/base/conf/antrea-agent.conf b/build/yamls/windows/base/conf/antrea-agent.conf
@@ -5,6 +5,11 @@ featureGates:
 # Service traffic.
 #  AntreaProxy: true
 
+# Enable EndpointSlice support in AntreaProxy. Don't enable this feature unless that EndpointSlice
+# API version v1beta1 is supported and set as enabled in Kubernetes. If AntreaProxy is not enabled,
+# this flag will not take effect.
+#  EndpointSlice: false
+
 # Enable flowexporter which exports polled conntrack connections as IPFIX flow records from each agent to a configured collector.
 #  FlowExporter: false
 

diff --git a/third_party/proxy/config/config.go b/third_party/proxy/config/config.go
@@ -330,7 +330,7 @@ func (c *EndpointSliceConfig) handleAddEndpointSlice(obj interface{}) {
 		return
 	}
 	for _, h := range c.eventHandlers {
-		klog.V(4).Infof("Calling handler.OnEndpointSliceAdd %+v", endpointSlice)
+		klog.V(4).InfoS("Calling handler.OnEndpointSliceAdd", "endpointSlice", endpointSlice)
 		h.OnEndpointSliceAdd(endpointSlice)
 	}
 }
@@ -347,7 +347,7 @@ func (c *EndpointSliceConfig) handleUpdateEndpointSlice(oldObj, newObj interface
 		return
 	}
 	for _, h := range c.eventHandlers {
-		klog.V(4).Infof("Calling handler.OnEndpointSliceUpdate")
+		klog.V(4).InfoS("Calling handler.OnEndpointSliceUpdate", "from", oldEndpointSlice, "to", newEndpointSlice)
 		h.OnEndpointSliceUpdate(oldEndpointSlice, newEndpointSlice)
 	}
 }
@@ -366,7 +366,7 @@ func (c *EndpointSliceConfig) handleDeleteEndpointSlice(obj interface{}) {
 		}
 	}
 	for _, h := range c.eventHandlers {
-		klog.V(4).Infof("Calling handler.OnEndpointsDelete")
+		klog.V(4).InfoS("Calling handler.OnEndpointSliceDelete", "endpointSlice", endpointSlice)
 		h.OnEndpointSliceDelete(endpointSlice)
 	}
 }