feat: support api query.

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

Hide file tree

Showing 31 changed files with 1,495 additions and 174 deletions.
diff --git a/build/charts/antrea/templates/antctl/clusterrole.yaml b/build/charts/antrea/templates/antctl/clusterrole.yaml
@@ -26,6 +26,7 @@ rules:
       - networkpolicystats
       - antreaclusternetworkpolicystats
       - antreanetworkpolicystats
+      - nodeiplatencystat
     verbs:
       - get
       - list

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 mod download
+    go env -w GOPROXY=https://goproxy.cn,direct;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 mod download
+    go env -w GOPROXY=https://goproxy.cn,direct;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 mod download
+    go env -w GOPROXY=https://goproxy.cn,direct;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 mod download
+    go env -w GOPROXY=https://goproxy.cn,direct;go mod download
 
 COPY . /antrea
 

diff --git a/build/yamls/antrea-aks.yml b/build/yamls/antrea-aks.yml
@@ -4405,6 +4405,7 @@ rules:
       - networkpolicystats
       - antreaclusternetworkpolicystats
       - antreanetworkpolicystats
+      - nodeiplatencystat
     verbs:
       - get
       - list

diff --git a/build/yamls/antrea-eks.yml b/build/yamls/antrea-eks.yml
@@ -4405,6 +4405,7 @@ rules:
       - networkpolicystats
       - antreaclusternetworkpolicystats
       - antreanetworkpolicystats
+      - nodeiplatencystat
     verbs:
       - get
       - list

diff --git a/build/yamls/antrea-gke.yml b/build/yamls/antrea-gke.yml
@@ -4405,6 +4405,7 @@ rules:
       - networkpolicystats
       - antreaclusternetworkpolicystats
       - antreanetworkpolicystats
+      - nodeiplatencystat
     verbs:
       - get
       - list

diff --git a/build/yamls/antrea-ipsec.yml b/build/yamls/antrea-ipsec.yml
@@ -4418,6 +4418,7 @@ rules:
       - networkpolicystats
       - antreaclusternetworkpolicystats
       - antreanetworkpolicystats
+      - nodeiplatencystat
     verbs:
       - get
       - list

diff --git a/build/yamls/antrea.yml b/build/yamls/antrea.yml
@@ -4405,6 +4405,7 @@ rules:
       - networkpolicystats
       - antreaclusternetworkpolicystats
       - antreanetworkpolicystats
+      - nodeiplatencystat
     verbs:
       - get
       - list

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 mod download
+    go env -w GOPROXY=https://goproxy.cn,direct;go mod download
 
 COPY . /antrea
 

diff --git a/multicluster/hack/update-codegen-dockerized.sh b/multicluster/hack/update-codegen-dockerized.sh
@@ -43,14 +43,14 @@ function generate_multicluster_client_code {
     --input "multicluster/v1alpha2" \
     --output-package "${ANTREA_PKG}/multicluster/pkg/client/clientset" \
     --go-header-file hack/boilerplate/license_header.go.txt
-  
+
   # Generate listers with K8s codegen tools.
   $GOPATH/bin/lister-gen \
     --input-dirs "${ANTREA_PKG}/multicluster/apis/multicluster/v1alpha1" \
     --input-dirs "${ANTREA_PKG}/multicluster/apis/multicluster/v1alpha2" \
     --output-package "${ANTREA_PKG}/multicluster/pkg/client/listers" \
     --go-header-file hack/boilerplate/license_header.go.txt
-  
+
   # Generate informers with K8s codegen tools.
   $GOPATH/bin/informer-gen \
     --input-dirs "${ANTREA_PKG}/multicluster/apis/multicluster/v1alpha1" \

diff --git a/pkg/apis/controlplane/register.go b/pkg/apis/controlplane/register.go
@@ -67,7 +67,6 @@ func addKnownTypes(scheme *runtime.Scheme) error {
 		&SupportBundleCollection{},
 		&SupportBundleCollectionList{},
 		&SupportBundleCollectionStatus{},
-		// &NodeIPLatencyStat{},
 	)
 	return nil
 }
diff --git a/pkg/apis/controlplane/types.go b/pkg/apis/controlplane/types.go
@@ -408,31 +408,6 @@ type NodeStatsSummary struct {
 	Multicast []MulticastGroupInfo
 }
 
-// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
-
-// NodeIPLatencyStat contains the latency stat of a Node.
-type NodeIPLatencyStat struct {
-	metav1.TypeMeta
-	metav1.ObjectMeta
-
-	// The list of NodeIPLatency.
-	NodeIPLatencyList []NodeIPLatencyEntry
-}
-
-// NodeIPLatencyEntry contains the latency stats of a Node.
-type NodeIPLatencyEntry struct {
-	// The Node's name.
-	NodeName string
-	// The Node's target IP address.
-	TargetIP string
-	// The timestamp of the last send packet.
-	LastSendTime int64
-	// The timestamp of the last receive packet.
-	LastRecvTime int64
-	// The last valid rtt of the Node.
-	LastMeasuredRTT int64
-}
-
 // MulticastGroupInfo contains the list of Pods that have joined a multicast group, for a given Node.
 type MulticastGroupInfo struct {
 	// Group is the IP of the multicast group.