fix: add delete api define and remove watch api.

Signed-off-by: Asklv <[email protected]>

pkg/agent/monitortool/latency_store.go

@@ -27,7 +27,6 @@ import (
 	"k8s.io/klog/v2"
 
 	statsv1alpha1 "antrea.io/antrea/pkg/apis/stats/v1alpha1"
-
 	"antrea.io/antrea/pkg/util/k8s"
 )
 

pkg/agent/monitortool/monitor.go

@@ -32,11 +32,10 @@ import (
 	"k8s.io/klog/v2"
 	"k8s.io/utils/clock"
 
-	statsv1alpha1 "antrea.io/antrea/pkg/apis/stats/v1alpha1"
-
 	"antrea.io/antrea/pkg/agent/client"
 	"antrea.io/antrea/pkg/agent/config"
 	"antrea.io/antrea/pkg/apis/crd/v1alpha1"
+	statsv1alpha1 "antrea.io/antrea/pkg/apis/stats/v1alpha1"
 	crdinformers "antrea.io/antrea/pkg/client/informers/externalversions/crd/v1alpha1"
 )
 
@@ -376,8 +375,8 @@ func (m *NodeLatencyMonitor) pingAll(ipv4Socket, ipv6Socket net.PacketConn) {
 	klog.V(4).InfoS("Done pinging all Nodes")
 }
 
-// GetSummary returns the latency summary of the given Node IP.
-func (m *NodeLatencyMonitor) GetSummary() *statsv1alpha1.NodeLatencyStats {
+// getSummary returns the latency summary of the given Node IP.
+func (m *NodeLatencyMonitor) getSummary() *statsv1alpha1.NodeLatencyStats {
 	return &statsv1alpha1.NodeLatencyStats{
 		ObjectMeta: metav1.ObjectMeta{
 			Name: m.nodeName,
@@ -387,7 +386,7 @@ func (m *NodeLatencyMonitor) GetSummary() *statsv1alpha1.NodeLatencyStats {
 }
 
 func (m *NodeLatencyMonitor) report() {
-	summary := m.GetSummary()
+	summary := m.getSummary()
 	antreaClient, err := m.antreaClientProvider.GetAntreaClient()
 	if err != nil {
 		klog.ErrorS(err, "Failed to get Antrea client")

pkg/apis/stats/v1alpha1/types.go

@@ -150,7 +150,7 @@ type RuleTrafficStats struct {
 // +genclient
 // +genclient:nonNamespaced
 // +resourceName=nodelatencystats
-// +genclient:onlyVerbs=create,delete,get,list,watch
+// +genclient:onlyVerbs=create,delete,get,list
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
 
 // NodeLatencyStats contains all the latency measurements collected by the Agent from a specific Node.

pkg/apiserver/apiserver.go

@@ -58,7 +58,7 @@ import (
 	"antrea.io/antrea/pkg/apiserver/registry/stats/antreanetworkpolicystats"
 	"antrea.io/antrea/pkg/apiserver/registry/stats/multicastgroup"
 	"antrea.io/antrea/pkg/apiserver/registry/stats/networkpolicystats"
-	nodelatencystat "antrea.io/antrea/pkg/apiserver/registry/stats/nodelatencystats"
+	"antrea.io/antrea/pkg/apiserver/registry/stats/nodelatencystats"
 	"antrea.io/antrea/pkg/apiserver/registry/system/controllerinfo"
 	"antrea.io/antrea/pkg/apiserver/registry/system/supportbundle"
 	"antrea.io/antrea/pkg/apiserver/storage"
@@ -241,7 +241,7 @@ func installAPIGroup(s *APIServer, c completedConfig) error {
 	statsStorage["antreaclusternetworkpolicystats"] = antreaclusternetworkpolicystats.NewREST(c.extraConfig.statsAggregator)
 	statsStorage["antreanetworkpolicystats"] = antreanetworkpolicystats.NewREST(c.extraConfig.statsAggregator)
 	statsStorage["multicastgroups"] = multicastgroup.NewREST(c.extraConfig.statsAggregator)
-	statsStorage["nodelatencystats"] = nodelatencystat.NewREST()
+	statsStorage["nodelatencystats"] = nodelatencystats.NewREST()
 	statsGroup.VersionedResourcesStorageMap["v1alpha1"] = statsStorage
 
 	groups := []*genericapiserver.APIGroupInfo{&cpGroup, &systemGroup, &statsGroup}

pkg/apiserver/registry/stats/nodelatencystats/rest.go

@@ -33,6 +33,7 @@ var (
 	_ rest.Scoper               = &REST{}
 	_ rest.Getter               = &REST{}
 	_ rest.Lister               = &REST{}
+	_ rest.GracefulDeleter      = &REST{}
 	_ rest.SingularNameProvider = &REST{}
 )
 
@@ -79,6 +80,10 @@ func (r *REST) ConvertToTable(ctx context.Context, obj runtime.Object, tableOpti
 	return table, nil
 }
 
+func (r *REST) Delete(ctx context.Context, name string, deleteValidation rest.ValidateObjectFunc, options *metav1.DeleteOptions) (runtime.Object, bool, error) {
+	return &statsv1alpha1.NodeLatencyStats{}, true, nil
+}
+
 func (r *REST) NamespaceScoped() bool {
 	return false
 }