feat: support api send and query.

antrea-io · Jun 3, 2024 · fc9b23c · fc9b23c
1 parent 63576b7
commit fc9b23c
Show file tree

Hide file tree

Showing 23 changed files with 196 additions and 213 deletions.
diff --git a/build/charts/antrea/templates/agent/clusterrole.yaml b/build/charts/antrea/templates/agent/clusterrole.yaml
@@ -5,6 +5,18 @@ metadata:
   labels:
     app: antrea
 rules:
+  - apiGroups:
+      - stats.antrea.io
+    resources:
+      - networkpolicystats
+      - antreaclusternetworkpolicystats
+      - antreanetworkpolicystats
+      - nodeiplatencystats
+    verbs:
+      - get
+      - list
+      - create
+      - update
   - apiGroups:
       - ""
     resources:
@@ -82,14 +94,6 @@ rules:
       - nodestatssummaries
     verbs:
       - create
-  - apiGroups:
-      - controlplane.antrea.io
-    resources:
-      - nodeiplatencystats
-    verbs:
-      - create
-      - get
-      - list
   - apiGroups:
       - controlplane.antrea.io
     resources:

diff --git a/build/charts/antrea/templates/antctl/clusterrole.yaml b/build/charts/antrea/templates/antctl/clusterrole.yaml
@@ -26,10 +26,12 @@ rules:
       - networkpolicystats
       - antreaclusternetworkpolicystats
       - antreanetworkpolicystats
-      - nodeiplatencystat
+      - nodeiplatencystats
     verbs:
       - get
       - list
+      - create
+      - update
   - apiGroups:
       - system.antrea.io
     resources:

diff --git a/build/images/Dockerfile.build.agent.ubi b/build/images/Dockerfile.build.agent.ubi
@@ -21,7 +21,7 @@ WORKDIR /antrea
 RUN --mount=type=cache,target=/go/pkg/mod/ \
     --mount=type=bind,source=go.sum,target=go.sum \
     --mount=type=bind,source=go.mod,target=go.mod \
-    go env -w GOPROXY=https://goproxy.cn,direct;go mod download
+    go mod download
 
 COPY . /antrea
 

diff --git a/build/images/Dockerfile.build.agent.ubuntu b/build/images/Dockerfile.build.agent.ubuntu
@@ -21,7 +21,7 @@ WORKDIR /antrea
 RUN --mount=type=cache,target=/go/pkg/mod/ \
     --mount=type=bind,source=go.sum,target=go.sum \
     --mount=type=bind,source=go.mod,target=go.mod \
-    go env -w GOPROXY=https://goproxy.cn,direct;go mod download
+    go mod download
 
 COPY . /antrea
 

diff --git a/build/images/Dockerfile.build.controller.ubi b/build/images/Dockerfile.build.controller.ubi
@@ -21,7 +21,7 @@ WORKDIR /antrea
 RUN --mount=type=cache,target=/go/pkg/mod/ \
     --mount=type=bind,source=go.sum,target=go.sum \
     --mount=type=bind,source=go.mod,target=go.mod \
-    go env -w GOPROXY=https://goproxy.cn,direct;go mod download
+    go mod download
 
 COPY . /antrea
 

diff --git a/build/images/Dockerfile.build.controller.ubuntu b/build/images/Dockerfile.build.controller.ubuntu
@@ -21,7 +21,7 @@ WORKDIR /antrea
 RUN --mount=type=cache,target=/go/pkg/mod/ \
     --mount=type=bind,source=go.sum,target=go.sum \
     --mount=type=bind,source=go.mod,target=go.mod \
-    go env -w GOPROXY=https://goproxy.cn,direct;go mod download
+    go mod download
 
 COPY . /antrea
 

diff --git a/build/yamls/antrea-aks.yml b/build/yamls/antrea-aks.yml
@@ -4144,6 +4144,18 @@ metadata:
   labels:
     app: antrea
 rules:
+  - apiGroups:
+      - stats.antrea.io
+    resources:
+      - networkpolicystats
+      - antreaclusternetworkpolicystats
+      - antreanetworkpolicystats
+      - nodeiplatencystats
+    verbs:
+      - get
+      - list
+      - create
+      - update
   - apiGroups:
       - ""
     resources:
@@ -4221,14 +4233,6 @@ rules:
       - nodestatssummaries
     verbs:
       - create
-  - apiGroups:
-      - controlplane.antrea.io
-    resources:
-      - nodeiplatencystats
-    verbs:
-      - create
-      - get
-      - list
   - apiGroups:
       - controlplane.antrea.io
     resources:
@@ -4405,10 +4409,12 @@ rules:
       - networkpolicystats
       - antreaclusternetworkpolicystats
       - antreanetworkpolicystats
-      - nodeiplatencystat
+      - nodeiplatencystats
     verbs:
       - get
       - list
+      - create
+      - update
   - apiGroups:
       - system.antrea.io
     resources:

diff --git a/build/yamls/antrea-eks.yml b/build/yamls/antrea-eks.yml
@@ -4144,6 +4144,18 @@ metadata:
   labels:
     app: antrea
 rules:
+  - apiGroups:
+      - stats.antrea.io
+    resources:
+      - networkpolicystats
+      - antreaclusternetworkpolicystats
+      - antreanetworkpolicystats
+      - nodeiplatencystats
+    verbs:
+      - get
+      - list
+      - create
+      - update
   - apiGroups:
       - ""
     resources:
@@ -4221,14 +4233,6 @@ rules:
       - nodestatssummaries
     verbs:
       - create
-  - apiGroups:
-      - controlplane.antrea.io
-    resources:
-      - nodeiplatencystats
-    verbs:
-      - create
-      - get
-      - list
   - apiGroups:
       - controlplane.antrea.io
     resources:
@@ -4405,10 +4409,12 @@ rules:
       - networkpolicystats
       - antreaclusternetworkpolicystats
       - antreanetworkpolicystats
-      - nodeiplatencystat
+      - nodeiplatencystats
     verbs:
       - get
       - list
+      - create
+      - update
   - apiGroups:
       - system.antrea.io
     resources:

diff --git a/build/yamls/antrea-gke.yml b/build/yamls/antrea-gke.yml
@@ -4144,6 +4144,18 @@ metadata:
   labels:
     app: antrea
 rules:
+  - apiGroups:
+      - stats.antrea.io
+    resources:
+      - networkpolicystats
+      - antreaclusternetworkpolicystats
+      - antreanetworkpolicystats
+      - nodeiplatencystats
+    verbs:
+      - get
+      - list
+      - create
+      - update
   - apiGroups:
       - ""
     resources:
@@ -4221,14 +4233,6 @@ rules:
       - nodestatssummaries
     verbs:
       - create
-  - apiGroups:
-      - controlplane.antrea.io
-    resources:
-      - nodeiplatencystats
-    verbs:
-      - create
-      - get
-      - list
   - apiGroups:
       - controlplane.antrea.io
     resources:
@@ -4405,10 +4409,12 @@ rules:
       - networkpolicystats
       - antreaclusternetworkpolicystats
       - antreanetworkpolicystats
-      - nodeiplatencystat
+      - nodeiplatencystats
     verbs:
       - get
       - list
+      - create
+      - update
   - apiGroups:
       - system.antrea.io
     resources:

diff --git a/build/yamls/antrea-ipsec.yml b/build/yamls/antrea-ipsec.yml
@@ -4157,6 +4157,18 @@ metadata:
   labels:
     app: antrea
 rules:
+  - apiGroups:
+      - stats.antrea.io
+    resources:
+      - networkpolicystats
+      - antreaclusternetworkpolicystats
+      - antreanetworkpolicystats
+      - nodeiplatencystats
+    verbs:
+      - get
+      - list
+      - create
+      - update
   - apiGroups:
       - ""
     resources:
@@ -4234,14 +4246,6 @@ rules:
       - nodestatssummaries
     verbs:
       - create
-  - apiGroups:
-      - controlplane.antrea.io
-    resources:
-      - nodeiplatencystats
-    verbs:
-      - create
-      - get
-      - list
   - apiGroups:
       - controlplane.antrea.io
     resources:
@@ -4418,10 +4422,12 @@ rules:
       - networkpolicystats
       - antreaclusternetworkpolicystats
       - antreanetworkpolicystats
-      - nodeiplatencystat
+      - nodeiplatencystats
     verbs:
       - get
       - list
+      - create
+      - update
   - apiGroups:
       - system.antrea.io
     resources:

diff --git a/build/yamls/antrea.yml b/build/yamls/antrea.yml
@@ -4144,6 +4144,18 @@ metadata:
   labels:
     app: antrea
 rules:
+  - apiGroups:
+      - stats.antrea.io
+    resources:
+      - networkpolicystats
+      - antreaclusternetworkpolicystats
+      - antreanetworkpolicystats
+      - nodeiplatencystats
+    verbs:
+      - get
+      - list
+      - create
+      - update
   - apiGroups:
       - ""
     resources:
@@ -4221,14 +4233,6 @@ rules:
       - nodestatssummaries
     verbs:
       - create
-  - apiGroups:
-      - controlplane.antrea.io
-    resources:
-      - nodeiplatencystats
-    verbs:
-      - create
-      - get
-      - list
   - apiGroups:
       - controlplane.antrea.io
     resources:
@@ -4405,10 +4409,12 @@ rules:
       - networkpolicystats
       - antreaclusternetworkpolicystats
       - antreanetworkpolicystats
-      - nodeiplatencystat
+      - nodeiplatencystats
     verbs:
       - get
       - list
+      - create
+      - update
   - apiGroups:
       - system.antrea.io
     resources:

diff --git a/cmd/antrea-agent/agent.go b/cmd/antrea-agent/agent.go
@@ -934,16 +934,16 @@ func run(o *Options) error {
 	}
 
 	// Start the node latency monitor.
-	// if features.DefaultFeatureGate.Enabled(features.NodeLatencyMonitor) && o.nodeType == config.K8sNode {
-	nodeLatencyMonitor := monitortool.NewNodeLatencyMonitor(
-		antreaClientProvider,
-		nodeInformer,
-		nodeLatencyMonitorInformer,
-		nodeConfig,
-		networkConfig.TrafficEncapMode,
-	)
-	go nodeLatencyMonitor.Run(stopCh)
-	// }
+	if features.DefaultFeatureGate.Enabled(features.NodeLatencyMonitor) && o.nodeType == config.K8sNode {
+		nodeLatencyMonitor := monitortool.NewNodeLatencyMonitor(
+			antreaClientProvider,
+			nodeInformer,
+			nodeLatencyMonitorInformer,
+			nodeConfig,
+			networkConfig.TrafficEncapMode,
+		)
+		go nodeLatencyMonitor.Run(stopCh)
+	}
 
 	<-stopCh
 	klog.Info("Stopping Antrea agent")

diff --git a/multicluster/build/images/Dockerfile.build b/multicluster/build/images/Dockerfile.build
@@ -20,7 +20,7 @@ WORKDIR /antrea
 RUN --mount=type=cache,target=/go/pkg/mod/ \
     --mount=type=bind,source=go.sum,target=go.sum \
     --mount=type=bind,source=go.mod,target=go.mod \
-    go env -w GOPROXY=https://goproxy.cn,direct;go mod download
+    go mod download
 
 COPY . /antrea