From 4fa4de48b123869edf074ef98a5e1bc232682d16 Mon Sep 17 00:00:00 2001 From: rambohe-ch Date: Sun, 18 Jun 2023 22:53:18 +0800 Subject: [PATCH] delete unused functions --- .../servicetopology/adapter/adapter.go | 33 ------------------- 1 file changed, 33 deletions(-) diff --git a/pkg/controller/servicetopology/adapter/adapter.go b/pkg/controller/servicetopology/adapter/adapter.go index 3446f4cae46..dd559dd70c2 100644 --- a/pkg/controller/servicetopology/adapter/adapter.go +++ b/pkg/controller/servicetopology/adapter/adapter.go @@ -22,12 +22,9 @@ import ( "time" corev1 "k8s.io/api/core/v1" - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/client-go/tools/cache" - - "github.com/openyurtio/openyurt/pkg/yurthub/filter/servicetopology" ) type Adapter interface { @@ -53,36 +50,6 @@ func appendKeys(keys []string, obj interface{}) []string { return keys } -func isNodePoolTypeSvc(namespace, name string, svcTopologyTypes map[string]string) bool { - svc := &corev1.Service{ - ObjectMeta: metav1.ObjectMeta{ - Namespace: namespace, - Name: name, - }, - } - key, err := cache.MetaNamespaceKeyFunc(svc) - if err != nil { - runtime.HandleError(err) - return false - } - - return isNodePoolTypeTopology(svcTopologyTypes[key]) -} - -// TODO: if service topology need to support multi types, -// like openyurt.io/topologyKeys: "kubernetes.io/hostname, openyurt.io/nodepool, *". -// For simplicity,as long as the value of service topology annotation contains nodepool type, -// then this topology is recognized as nodepool type -func isNodePoolTypeTopology(topologyType string) bool { - if topologyType == servicetopology.AnnotationServiceTopologyValueNodePool { - return true - } - if topologyType == servicetopology.AnnotationServiceTopologyValueZone { - return true - } - return false -} - func getUpdateTriggerPatch() []byte { patch := fmt.Sprintf(`{"metadata":{"annotations": {"openyurt.io/update-trigger": "%d"}}}`, time.Now().Unix()) return []byte(patch)