mirror of
				https://github.com/optim-enterprises-bv/kubernetes.git
				synced 2025-10-31 18:28:13 +00:00 
			
		
		
		
	move util/metrics to component-base
Signed-off-by: Yassine TIJANI <ytijani@vmware.com>
This commit is contained in:
		| @@ -86,7 +86,6 @@ go_library( | |||||||
|         "//pkg/serviceaccount:go_default_library", |         "//pkg/serviceaccount:go_default_library", | ||||||
|         "//pkg/util/configz:go_default_library", |         "//pkg/util/configz:go_default_library", | ||||||
|         "//pkg/util/flag:go_default_library", |         "//pkg/util/flag:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//pkg/volume:go_default_library", |         "//pkg/volume:go_default_library", | ||||||
|         "//pkg/volume/awsebs:go_default_library", |         "//pkg/volume/awsebs:go_default_library", | ||||||
|         "//pkg/volume/azure_dd:go_default_library", |         "//pkg/volume/azure_dd:go_default_library", | ||||||
| @@ -139,6 +138,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/cloud-provider:go_default_library", |         "//staging/src/k8s.io/cloud-provider:go_default_library", | ||||||
|         "//staging/src/k8s.io/component-base/cli/flag:go_default_library", |         "//staging/src/k8s.io/component-base/cli/flag:go_default_library", | ||||||
|         "//staging/src/k8s.io/component-base/cli/globalflag:go_default_library", |         "//staging/src/k8s.io/component-base/cli/globalflag:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//staging/src/k8s.io/component-base/version:go_default_library", |         "//staging/src/k8s.io/component-base/version:go_default_library", | ||||||
|         "//staging/src/k8s.io/component-base/version/verflag:go_default_library", |         "//staging/src/k8s.io/component-base/version/verflag:go_default_library", | ||||||
|         "//staging/src/k8s.io/csi-translation-lib:go_default_library", |         "//staging/src/k8s.io/csi-translation-lib:go_default_library", | ||||||
|   | |||||||
| @@ -36,6 +36,7 @@ import ( | |||||||
| 	clientset "k8s.io/client-go/kubernetes" | 	clientset "k8s.io/client-go/kubernetes" | ||||||
| 	"k8s.io/client-go/metadata" | 	"k8s.io/client-go/metadata" | ||||||
| 	restclient "k8s.io/client-go/rest" | 	restclient "k8s.io/client-go/rest" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	csitrans "k8s.io/csi-translation-lib" | 	csitrans "k8s.io/csi-translation-lib" | ||||||
| 	"k8s.io/kubernetes/pkg/controller" | 	"k8s.io/kubernetes/pkg/controller" | ||||||
| 	cloudcontroller "k8s.io/kubernetes/pkg/controller/cloud" | 	cloudcontroller "k8s.io/kubernetes/pkg/controller/cloud" | ||||||
| @@ -62,7 +63,6 @@ import ( | |||||||
| 	kubefeatures "k8s.io/kubernetes/pkg/features" | 	kubefeatures "k8s.io/kubernetes/pkg/features" | ||||||
| 	"k8s.io/kubernetes/pkg/quota/v1/generic" | 	"k8s.io/kubernetes/pkg/quota/v1/generic" | ||||||
| 	quotainstall "k8s.io/kubernetes/pkg/quota/v1/install" | 	quotainstall "k8s.io/kubernetes/pkg/quota/v1/install" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| 	netutils "k8s.io/utils/net" | 	netutils "k8s.io/utils/net" | ||||||
| ) | ) | ||||||
|  |  | ||||||
| @@ -370,7 +370,7 @@ func startResourceQuotaController(ctx ControllerContext) (http.Handler, bool, er | |||||||
| 		Registry:                  generic.NewRegistry(quotaConfiguration.Evaluators()), | 		Registry:                  generic.NewRegistry(quotaConfiguration.Evaluators()), | ||||||
| 	} | 	} | ||||||
| 	if resourceQuotaControllerClient.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if resourceQuotaControllerClient.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		if err := metrics.RegisterMetricAndTrackRateLimiterUsage("resource_quota_controller", resourceQuotaControllerClient.CoreV1().RESTClient().GetRateLimiter()); err != nil { | 		if err := ratelimiter.RegisterMetricAndTrackRateLimiterUsage("resource_quota_controller", resourceQuotaControllerClient.CoreV1().RESTClient().GetRateLimiter()); err != nil { | ||||||
| 			return nil, true, err | 			return nil, true, err | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|   | |||||||
| @@ -77,7 +77,6 @@ | |||||||
| 				"k8s.io/kubernetes/pkg/util/conntrack", | 				"k8s.io/kubernetes/pkg/util/conntrack", | ||||||
| 				"k8s.io/kubernetes/pkg/util/hash", | 				"k8s.io/kubernetes/pkg/util/hash", | ||||||
| 				"k8s.io/kubernetes/pkg/util/iptables", | 				"k8s.io/kubernetes/pkg/util/iptables", | ||||||
| 				"k8s.io/kubernetes/pkg/util/metrics", |  | ||||||
| 				"k8s.io/kubernetes/pkg/util/parsers", | 				"k8s.io/kubernetes/pkg/util/parsers", | ||||||
| 				"k8s.io/kubernetes/pkg/util/sysctl", | 				"k8s.io/kubernetes/pkg/util/sysctl", | ||||||
| 				"k8s.io/kubernetes/pkg/util/taints" | 				"k8s.io/kubernetes/pkg/util/taints" | ||||||
|   | |||||||
| @@ -244,7 +244,6 @@ | |||||||
|         "k8s.io/kubernetes/pkg/util/goroutinemap/exponentialbackoff", |         "k8s.io/kubernetes/pkg/util/goroutinemap/exponentialbackoff", | ||||||
|         "k8s.io/kubernetes/pkg/util/hash", |         "k8s.io/kubernetes/pkg/util/hash", | ||||||
|         "k8s.io/kubernetes/pkg/util/labels", |         "k8s.io/kubernetes/pkg/util/labels", | ||||||
|         "k8s.io/kubernetes/pkg/util/metrics", |  | ||||||
|         "k8s.io/kubernetes/pkg/util/mount", |         "k8s.io/kubernetes/pkg/util/mount", | ||||||
|         "k8s.io/kubernetes/pkg/util/node", |         "k8s.io/kubernetes/pkg/util/node", | ||||||
|         "k8s.io/kubernetes/pkg/util/slice", |         "k8s.io/kubernetes/pkg/util/slice", | ||||||
|   | |||||||
| @@ -13,7 +13,6 @@ go_library( | |||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/apis/core:go_default_library", |         "//pkg/apis/core:go_default_library", | ||||||
|         "//pkg/controller:go_default_library", |         "//pkg/controller:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", | ||||||
| @@ -28,6 +27,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/cluster-bootstrap/token/api:go_default_library", |         "//staging/src/k8s.io/cluster-bootstrap/token/api:go_default_library", | ||||||
|         "//staging/src/k8s.io/cluster-bootstrap/token/jws:go_default_library", |         "//staging/src/k8s.io/cluster-bootstrap/token/jws:go_default_library", | ||||||
|         "//staging/src/k8s.io/cluster-bootstrap/util/secrets:go_default_library", |         "//staging/src/k8s.io/cluster-bootstrap/util/secrets:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
| ) | ) | ||||||
|   | |||||||
| @@ -36,8 +36,8 @@ import ( | |||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
| 	bootstrapapi "k8s.io/cluster-bootstrap/token/api" | 	bootstrapapi "k8s.io/cluster-bootstrap/token/api" | ||||||
| 	jws "k8s.io/cluster-bootstrap/token/jws" | 	jws "k8s.io/cluster-bootstrap/token/jws" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	api "k8s.io/kubernetes/pkg/apis/core" | 	api "k8s.io/kubernetes/pkg/apis/core" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| ) | ) | ||||||
|  |  | ||||||
| // SignerOptions contains options for the Signer | // SignerOptions contains options for the Signer | ||||||
| @@ -105,7 +105,7 @@ func NewSigner(cl clientset.Interface, secrets informers.SecretInformer, configM | |||||||
| 		syncQueue:          workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "bootstrap_signer_queue"), | 		syncQueue:          workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "bootstrap_signer_queue"), | ||||||
| 	} | 	} | ||||||
| 	if cl.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if cl.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		if err := metrics.RegisterMetricAndTrackRateLimiterUsage("bootstrap_signer", cl.CoreV1().RESTClient().GetRateLimiter()); err != nil { | 		if err := ratelimiter.RegisterMetricAndTrackRateLimiterUsage("bootstrap_signer", cl.CoreV1().RESTClient().GetRateLimiter()); err != nil { | ||||||
| 			return nil, err | 			return nil, err | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|   | |||||||
| @@ -32,10 +32,10 @@ import ( | |||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
| 	bootstrapapi "k8s.io/cluster-bootstrap/token/api" | 	bootstrapapi "k8s.io/cluster-bootstrap/token/api" | ||||||
| 	bootstrapsecretutil "k8s.io/cluster-bootstrap/util/secrets" | 	bootstrapsecretutil "k8s.io/cluster-bootstrap/util/secrets" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| 	api "k8s.io/kubernetes/pkg/apis/core" | 	api "k8s.io/kubernetes/pkg/apis/core" | ||||||
| 	"k8s.io/kubernetes/pkg/controller" | 	"k8s.io/kubernetes/pkg/controller" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| ) | ) | ||||||
|  |  | ||||||
| // TokenCleanerOptions contains options for the TokenCleaner | // TokenCleanerOptions contains options for the TokenCleaner | ||||||
| @@ -82,7 +82,7 @@ func NewTokenCleaner(cl clientset.Interface, secrets coreinformers.SecretInforme | |||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	if cl.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if cl.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		if err := metrics.RegisterMetricAndTrackRateLimiterUsage("token_cleaner", cl.CoreV1().RESTClient().GetRateLimiter()); err != nil { | 		if err := ratelimiter.RegisterMetricAndTrackRateLimiterUsage("token_cleaner", cl.CoreV1().RESTClient().GetRateLimiter()); err != nil { | ||||||
| 			return nil, err | 			return nil, err | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|   | |||||||
| @@ -6,7 +6,6 @@ go_library( | |||||||
|     importpath = "k8s.io/kubernetes/pkg/controller/certificates/rootcacertpublisher", |     importpath = "k8s.io/kubernetes/pkg/controller/certificates/rootcacertpublisher", | ||||||
|     visibility = ["//visibility:public"], |     visibility = ["//visibility:public"], | ||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", | ||||||
| @@ -17,10 +16,25 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/listers/core/v1:go_default_library", |         "//staging/src/k8s.io/client-go/listers/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", |         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
| ) | ) | ||||||
|  |  | ||||||
|  | go_test( | ||||||
|  |     name = "go_default_test", | ||||||
|  |     srcs = ["publisher_test.go"], | ||||||
|  |     embed = [":go_default_library"], | ||||||
|  |     deps = [ | ||||||
|  |         "//pkg/controller:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/apimachinery/pkg/util/diff:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/client-go/informers:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/client-go/kubernetes/fake:go_default_library", | ||||||
|  |     ], | ||||||
|  | ) | ||||||
|  |  | ||||||
| filegroup( | filegroup( | ||||||
|     name = "package-srcs", |     name = "package-srcs", | ||||||
|     srcs = glob(["**"]), |     srcs = glob(["**"]), | ||||||
| @@ -34,17 +48,3 @@ filegroup( | |||||||
|     tags = ["automanaged"], |     tags = ["automanaged"], | ||||||
|     visibility = ["//visibility:public"], |     visibility = ["//visibility:public"], | ||||||
| ) | ) | ||||||
|  |  | ||||||
| go_test( |  | ||||||
|     name = "go_default_test", |  | ||||||
|     srcs = ["publisher_test.go"], |  | ||||||
|     embed = [":go_default_library"], |  | ||||||
|     deps = [ |  | ||||||
|         "//pkg/controller:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/util/diff:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/client-go/informers:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/client-go/kubernetes/fake:go_default_library", |  | ||||||
|     ], |  | ||||||
| ) |  | ||||||
|   | |||||||
| @@ -31,8 +31,8 @@ import ( | |||||||
| 	corelisters "k8s.io/client-go/listers/core/v1" | 	corelisters "k8s.io/client-go/listers/core/v1" | ||||||
| 	"k8s.io/client-go/tools/cache" | 	"k8s.io/client-go/tools/cache" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| ) | ) | ||||||
|  |  | ||||||
| // RootCACertConfigMapName is name of the configmap which stores certificates | // RootCACertConfigMapName is name of the configmap which stores certificates | ||||||
| @@ -49,7 +49,7 @@ func NewPublisher(cmInformer coreinformers.ConfigMapInformer, nsInformer coreinf | |||||||
| 		queue:  workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "root_ca_cert_publisher"), | 		queue:  workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "root_ca_cert_publisher"), | ||||||
| 	} | 	} | ||||||
| 	if cl.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if cl.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		if err := metrics.RegisterMetricAndTrackRateLimiterUsage("root_ca_cert_publisher", cl.CoreV1().RESTClient().GetRateLimiter()); err != nil { | 		if err := ratelimiter.RegisterMetricAndTrackRateLimiterUsage("root_ca_cert_publisher", cl.CoreV1().RESTClient().GetRateLimiter()); err != nil { | ||||||
| 			return nil, err | 			return nil, err | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|   | |||||||
| @@ -17,7 +17,6 @@ go_library( | |||||||
|     importpath = "k8s.io/kubernetes/pkg/controller/cronjob", |     importpath = "k8s.io/kubernetes/pkg/controller/cronjob", | ||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/api/legacyscheme:go_default_library", |         "//pkg/api/legacyscheme:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/batch/v1:go_default_library", |         "//staging/src/k8s.io/api/batch/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/api/batch/v1beta1:go_default_library", |         "//staging/src/k8s.io/api/batch/v1beta1:go_default_library", | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
| @@ -33,6 +32,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/tools/pager:go_default_library", |         "//staging/src/k8s.io/client-go/tools/pager:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/record:go_default_library", |         "//staging/src/k8s.io/client-go/tools/record:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/reference:go_default_library", |         "//staging/src/k8s.io/client-go/tools/reference:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/github.com/robfig/cron:go_default_library", |         "//vendor/github.com/robfig/cron:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
|   | |||||||
| @@ -50,7 +50,7 @@ import ( | |||||||
| 	"k8s.io/client-go/tools/pager" | 	"k8s.io/client-go/tools/pager" | ||||||
| 	"k8s.io/client-go/tools/record" | 	"k8s.io/client-go/tools/record" | ||||||
| 	ref "k8s.io/client-go/tools/reference" | 	ref "k8s.io/client-go/tools/reference" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| ) | ) | ||||||
|  |  | ||||||
| // Utilities for dealing with Jobs and CronJobs and time. | // Utilities for dealing with Jobs and CronJobs and time. | ||||||
| @@ -74,7 +74,7 @@ func NewController(kubeClient clientset.Interface) (*Controller, error) { | |||||||
| 	eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: kubeClient.CoreV1().Events("")}) | 	eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: kubeClient.CoreV1().Events("")}) | ||||||
|  |  | ||||||
| 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		if err := metrics.RegisterMetricAndTrackRateLimiterUsage("cronjob_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()); err != nil { | 		if err := ratelimiter.RegisterMetricAndTrackRateLimiterUsage("cronjob_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()); err != nil { | ||||||
| 			return nil, err | 			return nil, err | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|   | |||||||
| @@ -23,7 +23,6 @@ go_library( | |||||||
|         "//pkg/scheduler/algorithm/predicates:go_default_library", |         "//pkg/scheduler/algorithm/predicates:go_default_library", | ||||||
|         "//pkg/scheduler/nodeinfo:go_default_library", |         "//pkg/scheduler/nodeinfo:go_default_library", | ||||||
|         "//pkg/util/labels:go_default_library", |         "//pkg/util/labels:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/apps/v1:go_default_library", |         "//staging/src/k8s.io/api/apps/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/api/equality:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/api/equality:go_default_library", | ||||||
| @@ -50,6 +49,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/tools/record:go_default_library", |         "//staging/src/k8s.io/client-go/tools/record:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/flowcontrol:go_default_library", |         "//staging/src/k8s.io/client-go/util/flowcontrol:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|         "//vendor/k8s.io/utils/integer:go_default_library", |         "//vendor/k8s.io/utils/integer:go_default_library", | ||||||
|     ], |     ], | ||||||
|   | |||||||
| @@ -48,6 +48,7 @@ import ( | |||||||
| 	"k8s.io/client-go/tools/record" | 	"k8s.io/client-go/tools/record" | ||||||
| 	"k8s.io/client-go/util/flowcontrol" | 	"k8s.io/client-go/util/flowcontrol" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	podutil "k8s.io/kubernetes/pkg/api/v1/pod" | 	podutil "k8s.io/kubernetes/pkg/api/v1/pod" | ||||||
| 	"k8s.io/kubernetes/pkg/controller" | 	"k8s.io/kubernetes/pkg/controller" | ||||||
| 	"k8s.io/kubernetes/pkg/controller/daemon/util" | 	"k8s.io/kubernetes/pkg/controller/daemon/util" | ||||||
| @@ -55,7 +56,6 @@ import ( | |||||||
| 	kubelettypes "k8s.io/kubernetes/pkg/kubelet/types" | 	kubelettypes "k8s.io/kubernetes/pkg/kubelet/types" | ||||||
| 	"k8s.io/kubernetes/pkg/scheduler/algorithm/predicates" | 	"k8s.io/kubernetes/pkg/scheduler/algorithm/predicates" | ||||||
| 	schedulernodeinfo "k8s.io/kubernetes/pkg/scheduler/nodeinfo" | 	schedulernodeinfo "k8s.io/kubernetes/pkg/scheduler/nodeinfo" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| 	"k8s.io/utils/integer" | 	"k8s.io/utils/integer" | ||||||
| ) | ) | ||||||
|  |  | ||||||
| @@ -151,7 +151,7 @@ func NewDaemonSetsController( | |||||||
| 	eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: kubeClient.CoreV1().Events("")}) | 	eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: kubeClient.CoreV1().Events("")}) | ||||||
|  |  | ||||||
| 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		if err := metrics.RegisterMetricAndTrackRateLimiterUsage("daemon_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()); err != nil { | 		if err := ratelimiter.RegisterMetricAndTrackRateLimiterUsage("daemon_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()); err != nil { | ||||||
| 			return nil, err | 			return nil, err | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|   | |||||||
| @@ -21,7 +21,6 @@ go_library( | |||||||
|         "//pkg/controller:go_default_library", |         "//pkg/controller:go_default_library", | ||||||
|         "//pkg/controller/deployment/util:go_default_library", |         "//pkg/controller/deployment/util:go_default_library", | ||||||
|         "//pkg/util/labels:go_default_library", |         "//pkg/util/labels:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/apps/v1:go_default_library", |         "//staging/src/k8s.io/api/apps/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/api/extensions/v1beta1:go_default_library", |         "//staging/src/k8s.io/api/extensions/v1beta1:go_default_library", | ||||||
| @@ -41,6 +40,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", |         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/record:go_default_library", |         "//staging/src/k8s.io/client-go/tools/record:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|         "//vendor/k8s.io/utils/integer:go_default_library", |         "//vendor/k8s.io/utils/integer:go_default_library", | ||||||
|     ], |     ], | ||||||
|   | |||||||
| @@ -45,9 +45,9 @@ import ( | |||||||
| 	"k8s.io/client-go/tools/cache" | 	"k8s.io/client-go/tools/cache" | ||||||
| 	"k8s.io/client-go/tools/record" | 	"k8s.io/client-go/tools/record" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/kubernetes/pkg/controller" | 	"k8s.io/kubernetes/pkg/controller" | ||||||
| 	"k8s.io/kubernetes/pkg/controller/deployment/util" | 	"k8s.io/kubernetes/pkg/controller/deployment/util" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| ) | ) | ||||||
|  |  | ||||||
| const ( | const ( | ||||||
| @@ -103,7 +103,7 @@ func NewDeploymentController(dInformer appsinformers.DeploymentInformer, rsInfor | |||||||
| 	eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: client.CoreV1().Events("")}) | 	eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: client.CoreV1().Events("")}) | ||||||
|  |  | ||||||
| 	if client != nil && client.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if client != nil && client.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		if err := metrics.RegisterMetricAndTrackRateLimiterUsage("deployment_controller", client.CoreV1().RESTClient().GetRateLimiter()); err != nil { | 		if err := ratelimiter.RegisterMetricAndTrackRateLimiterUsage("deployment_controller", client.CoreV1().RESTClient().GetRateLimiter()); err != nil { | ||||||
| 			return nil, err | 			return nil, err | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|   | |||||||
| @@ -16,7 +16,6 @@ go_library( | |||||||
|         "//pkg/controller:go_default_library", |         "//pkg/controller:go_default_library", | ||||||
|         "//pkg/controller/util/endpoint:go_default_library", |         "//pkg/controller/util/endpoint:go_default_library", | ||||||
|         "//pkg/features:go_default_library", |         "//pkg/features:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/api/equality:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/api/equality:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", | ||||||
| @@ -35,6 +34,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/tools/leaderelection/resourcelock:go_default_library", |         "//staging/src/k8s.io/client-go/tools/leaderelection/resourcelock:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/record:go_default_library", |         "//staging/src/k8s.io/client-go/tools/record:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|         "//vendor/k8s.io/utils/net:go_default_library", |         "//vendor/k8s.io/utils/net:go_default_library", | ||||||
|     ], |     ], | ||||||
|   | |||||||
| @@ -39,6 +39,7 @@ import ( | |||||||
| 	"k8s.io/client-go/tools/leaderelection/resourcelock" | 	"k8s.io/client-go/tools/leaderelection/resourcelock" | ||||||
| 	"k8s.io/client-go/tools/record" | 	"k8s.io/client-go/tools/record" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| 	"k8s.io/kubernetes/pkg/api/v1/endpoints" | 	"k8s.io/kubernetes/pkg/api/v1/endpoints" | ||||||
| 	podutil "k8s.io/kubernetes/pkg/api/v1/pod" | 	podutil "k8s.io/kubernetes/pkg/api/v1/pod" | ||||||
| @@ -46,7 +47,6 @@ import ( | |||||||
| 	helper "k8s.io/kubernetes/pkg/apis/core/v1/helper" | 	helper "k8s.io/kubernetes/pkg/apis/core/v1/helper" | ||||||
| 	"k8s.io/kubernetes/pkg/controller" | 	"k8s.io/kubernetes/pkg/controller" | ||||||
| 	endpointutil "k8s.io/kubernetes/pkg/controller/util/endpoint" | 	endpointutil "k8s.io/kubernetes/pkg/controller/util/endpoint" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
|  |  | ||||||
| 	utilfeature "k8s.io/apiserver/pkg/util/feature" | 	utilfeature "k8s.io/apiserver/pkg/util/feature" | ||||||
| 	"k8s.io/kubernetes/pkg/features" | 	"k8s.io/kubernetes/pkg/features" | ||||||
| @@ -85,7 +85,7 @@ func NewEndpointController(podInformer coreinformers.PodInformer, serviceInforme | |||||||
| 	recorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "endpoint-controller"}) | 	recorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "endpoint-controller"}) | ||||||
|  |  | ||||||
| 	if client != nil && client.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if client != nil && client.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		metrics.RegisterMetricAndTrackRateLimiterUsage("endpoint_controller", client.CoreV1().RESTClient().GetRateLimiter()) | 		ratelimiter.RegisterMetricAndTrackRateLimiterUsage("endpoint_controller", client.CoreV1().RESTClient().GetRateLimiter()) | ||||||
| 	} | 	} | ||||||
| 	e := &EndpointController{ | 	e := &EndpointController{ | ||||||
| 		client:           client, | 		client:           client, | ||||||
|   | |||||||
| @@ -17,7 +17,6 @@ go_library( | |||||||
|         "//pkg/controller:go_default_library", |         "//pkg/controller:go_default_library", | ||||||
|         "//pkg/controller/util/endpoint:go_default_library", |         "//pkg/controller/util/endpoint:go_default_library", | ||||||
|         "//pkg/util/hash:go_default_library", |         "//pkg/util/hash:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/api/discovery/v1alpha1:go_default_library", |         "//staging/src/k8s.io/api/discovery/v1alpha1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/api/equality:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/api/equality:go_default_library", | ||||||
| @@ -39,6 +38,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", |         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/record:go_default_library", |         "//staging/src/k8s.io/client-go/tools/record:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
| ) | ) | ||||||
|   | |||||||
| @@ -36,10 +36,10 @@ import ( | |||||||
| 	"k8s.io/client-go/tools/cache" | 	"k8s.io/client-go/tools/cache" | ||||||
| 	"k8s.io/client-go/tools/record" | 	"k8s.io/client-go/tools/record" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| 	"k8s.io/kubernetes/pkg/controller" | 	"k8s.io/kubernetes/pkg/controller" | ||||||
| 	endpointutil "k8s.io/kubernetes/pkg/controller/util/endpoint" | 	endpointutil "k8s.io/kubernetes/pkg/controller/util/endpoint" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| ) | ) | ||||||
|  |  | ||||||
| const ( | const ( | ||||||
| @@ -69,7 +69,7 @@ func NewController(podInformer coreinformers.PodInformer, | |||||||
| 	recorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "endpoint-slice-controller"}) | 	recorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "endpoint-slice-controller"}) | ||||||
|  |  | ||||||
| 	if client != nil && client.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if client != nil && client.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		metrics.RegisterMetricAndTrackRateLimiterUsage("endpoint_slice_controller", client.DiscoveryV1alpha1().RESTClient().GetRateLimiter()) | 		ratelimiter.RegisterMetricAndTrackRateLimiterUsage("endpoint_slice_controller", client.DiscoveryV1alpha1().RESTClient().GetRateLimiter()) | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	c := &Controller{ | 	c := &Controller{ | ||||||
|   | |||||||
| @@ -16,7 +16,6 @@ go_library( | |||||||
|     importpath = "k8s.io/kubernetes/pkg/controller/job", |     importpath = "k8s.io/kubernetes/pkg/controller/job", | ||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/controller:go_default_library", |         "//pkg/controller:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/batch/v1:go_default_library", |         "//staging/src/k8s.io/api/batch/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", | ||||||
| @@ -34,6 +33,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", |         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/record:go_default_library", |         "//staging/src/k8s.io/client-go/tools/record:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|         "//vendor/k8s.io/utils/integer:go_default_library", |         "//vendor/k8s.io/utils/integer:go_default_library", | ||||||
|     ], |     ], | ||||||
|   | |||||||
| @@ -41,8 +41,8 @@ import ( | |||||||
| 	"k8s.io/client-go/tools/cache" | 	"k8s.io/client-go/tools/cache" | ||||||
| 	"k8s.io/client-go/tools/record" | 	"k8s.io/client-go/tools/record" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/kubernetes/pkg/controller" | 	"k8s.io/kubernetes/pkg/controller" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| 	"k8s.io/utils/integer" | 	"k8s.io/utils/integer" | ||||||
|  |  | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| @@ -95,7 +95,7 @@ func NewJobController(podInformer coreinformers.PodInformer, jobInformer batchin | |||||||
| 	eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: kubeClient.CoreV1().Events("")}) | 	eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: kubeClient.CoreV1().Events("")}) | ||||||
|  |  | ||||||
| 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		metrics.RegisterMetricAndTrackRateLimiterUsage("job_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()) | 		ratelimiter.RegisterMetricAndTrackRateLimiterUsage("job_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()) | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	jm := &JobController{ | 	jm := &JobController{ | ||||||
|   | |||||||
| @@ -1,9 +1,4 @@ | |||||||
| package(default_visibility = ["//visibility:public"]) | load("@io_bazel_rules_go//go:def.bzl", "go_library") | ||||||
|  |  | ||||||
| load( |  | ||||||
|     "@io_bazel_rules_go//go:def.bzl", |  | ||||||
|     "go_library", |  | ||||||
| ) |  | ||||||
|  |  | ||||||
| go_library( | go_library( | ||||||
|     name = "go_default_library", |     name = "go_default_library", | ||||||
| @@ -12,10 +7,10 @@ go_library( | |||||||
|         "namespace_controller.go", |         "namespace_controller.go", | ||||||
|     ], |     ], | ||||||
|     importpath = "k8s.io/kubernetes/pkg/controller/namespace", |     importpath = "k8s.io/kubernetes/pkg/controller/namespace", | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/controller:go_default_library", |         "//pkg/controller:go_default_library", | ||||||
|         "//pkg/controller/namespace/deletion:go_default_library", |         "//pkg/controller/namespace/deletion:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", | ||||||
| @@ -27,6 +22,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/metadata:go_default_library", |         "//staging/src/k8s.io/client-go/metadata:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", |         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/golang.org/x/time/rate:go_default_library", |         "//vendor/golang.org/x/time/rate:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
| @@ -47,4 +43,5 @@ filegroup( | |||||||
|         "//pkg/controller/namespace/deletion:all-srcs", |         "//pkg/controller/namespace/deletion:all-srcs", | ||||||
|     ], |     ], | ||||||
|     tags = ["automanaged"], |     tags = ["automanaged"], | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
| ) | ) | ||||||
|   | |||||||
| @@ -33,9 +33,9 @@ import ( | |||||||
| 	"k8s.io/client-go/metadata" | 	"k8s.io/client-go/metadata" | ||||||
| 	"k8s.io/client-go/tools/cache" | 	"k8s.io/client-go/tools/cache" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/kubernetes/pkg/controller" | 	"k8s.io/kubernetes/pkg/controller" | ||||||
| 	"k8s.io/kubernetes/pkg/controller/namespace/deletion" | 	"k8s.io/kubernetes/pkg/controller/namespace/deletion" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
|  |  | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| ) | ) | ||||||
| @@ -78,7 +78,7 @@ func NewNamespaceController( | |||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		metrics.RegisterMetricAndTrackRateLimiterUsage("namespace_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()) | 		ratelimiter.RegisterMetricAndTrackRateLimiterUsage("namespace_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()) | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	// configure the namespace informer event handlers | 	// configure the namespace informer event handlers | ||||||
|   | |||||||
| @@ -34,7 +34,6 @@ go_library( | |||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/controller/nodeipam/ipam:go_default_library", |         "//pkg/controller/nodeipam/ipam:go_default_library", | ||||||
|         "//pkg/controller/nodeipam/ipam/sync:go_default_library", |         "//pkg/controller/nodeipam/ipam/sync:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/util/runtime:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/util/runtime:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/informers/core/v1:go_default_library", |         "//staging/src/k8s.io/client-go/informers/core/v1:go_default_library", | ||||||
| @@ -44,6 +43,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", |         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/record:go_default_library", |         "//staging/src/k8s.io/client-go/tools/record:go_default_library", | ||||||
|         "//staging/src/k8s.io/cloud-provider:go_default_library", |         "//staging/src/k8s.io/cloud-provider:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
| ) | ) | ||||||
|   | |||||||
| @@ -33,8 +33,8 @@ import ( | |||||||
| 	clientset "k8s.io/client-go/kubernetes" | 	clientset "k8s.io/client-go/kubernetes" | ||||||
| 	corelisters "k8s.io/client-go/listers/core/v1" | 	corelisters "k8s.io/client-go/listers/core/v1" | ||||||
| 	cloudprovider "k8s.io/cloud-provider" | 	cloudprovider "k8s.io/cloud-provider" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/kubernetes/pkg/controller/nodeipam/ipam" | 	"k8s.io/kubernetes/pkg/controller/nodeipam/ipam" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| ) | ) | ||||||
|  |  | ||||||
| const ( | const ( | ||||||
| @@ -98,7 +98,7 @@ func NewNodeIpamController( | |||||||
| 		}) | 		}) | ||||||
|  |  | ||||||
| 	if kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		metrics.RegisterMetricAndTrackRateLimiterUsage("node_ipam_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()) | 		ratelimiter.RegisterMetricAndTrackRateLimiterUsage("node_ipam_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()) | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	// Cloud CIDR allocator does not rely on clusterCIDR or nodeCIDRMaskSize for allocation. | 	// Cloud CIDR allocator does not rely on clusterCIDR or nodeCIDRMaskSize for allocation. | ||||||
|   | |||||||
| @@ -16,7 +16,6 @@ go_library( | |||||||
|         "//pkg/features:go_default_library", |         "//pkg/features:go_default_library", | ||||||
|         "//pkg/kubelet/apis:go_default_library", |         "//pkg/kubelet/apis:go_default_library", | ||||||
|         "//pkg/scheduler/api:go_default_library", |         "//pkg/scheduler/api:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//pkg/util/node:go_default_library", |         "//pkg/util/node:go_default_library", | ||||||
|         "//pkg/util/taints:go_default_library", |         "//pkg/util/taints:go_default_library", | ||||||
|         "//staging/src/k8s.io/api/coordination/v1beta1:go_default_library", |         "//staging/src/k8s.io/api/coordination/v1beta1:go_default_library", | ||||||
| @@ -44,28 +43,11 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|         "//staging/src/k8s.io/component-base/metrics:go_default_library", |         "//staging/src/k8s.io/component-base/metrics:go_default_library", | ||||||
|         "//staging/src/k8s.io/component-base/metrics/legacyregistry:go_default_library", |         "//staging/src/k8s.io/component-base/metrics/legacyregistry:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
| ) | ) | ||||||
|  |  | ||||||
| filegroup( |  | ||||||
|     name = "package-srcs", |  | ||||||
|     srcs = glob(["**"]), |  | ||||||
|     tags = ["automanaged"], |  | ||||||
|     visibility = ["//visibility:private"], |  | ||||||
| ) |  | ||||||
|  |  | ||||||
| filegroup( |  | ||||||
|     name = "all-srcs", |  | ||||||
|     srcs = [ |  | ||||||
|         ":package-srcs", |  | ||||||
|         "//pkg/controller/nodelifecycle/config:all-srcs", |  | ||||||
|         "//pkg/controller/nodelifecycle/scheduler:all-srcs", |  | ||||||
|     ], |  | ||||||
|     tags = ["automanaged"], |  | ||||||
|     visibility = ["//visibility:public"], |  | ||||||
| ) |  | ||||||
|  |  | ||||||
| go_test( | go_test( | ||||||
|     name = "go_default_test", |     name = "go_default_test", | ||||||
|     srcs = ["node_lifecycle_controller_test.go"], |     srcs = ["node_lifecycle_controller_test.go"], | ||||||
| @@ -101,3 +83,21 @@ go_test( | |||||||
|         "//vendor/k8s.io/utils/pointer:go_default_library", |         "//vendor/k8s.io/utils/pointer:go_default_library", | ||||||
|     ], |     ], | ||||||
| ) | ) | ||||||
|  |  | ||||||
|  | filegroup( | ||||||
|  |     name = "package-srcs", | ||||||
|  |     srcs = glob(["**"]), | ||||||
|  |     tags = ["automanaged"], | ||||||
|  |     visibility = ["//visibility:private"], | ||||||
|  | ) | ||||||
|  |  | ||||||
|  | filegroup( | ||||||
|  |     name = "all-srcs", | ||||||
|  |     srcs = [ | ||||||
|  |         ":package-srcs", | ||||||
|  |         "//pkg/controller/nodelifecycle/config:all-srcs", | ||||||
|  |         "//pkg/controller/nodelifecycle/scheduler:all-srcs", | ||||||
|  |     ], | ||||||
|  |     tags = ["automanaged"], | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
|  | ) | ||||||
|   | |||||||
| @@ -52,6 +52,7 @@ import ( | |||||||
| 	"k8s.io/client-go/tools/record" | 	"k8s.io/client-go/tools/record" | ||||||
| 	"k8s.io/client-go/util/flowcontrol" | 	"k8s.io/client-go/util/flowcontrol" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	apicore "k8s.io/kubernetes/pkg/apis/core" | 	apicore "k8s.io/kubernetes/pkg/apis/core" | ||||||
| 	"k8s.io/kubernetes/pkg/controller" | 	"k8s.io/kubernetes/pkg/controller" | ||||||
| 	"k8s.io/kubernetes/pkg/controller/nodelifecycle/scheduler" | 	"k8s.io/kubernetes/pkg/controller/nodelifecycle/scheduler" | ||||||
| @@ -60,7 +61,6 @@ import ( | |||||||
| 	kubefeatures "k8s.io/kubernetes/pkg/features" | 	kubefeatures "k8s.io/kubernetes/pkg/features" | ||||||
| 	kubeletapis "k8s.io/kubernetes/pkg/kubelet/apis" | 	kubeletapis "k8s.io/kubernetes/pkg/kubelet/apis" | ||||||
| 	schedulerapi "k8s.io/kubernetes/pkg/scheduler/api" | 	schedulerapi "k8s.io/kubernetes/pkg/scheduler/api" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| 	utilnode "k8s.io/kubernetes/pkg/util/node" | 	utilnode "k8s.io/kubernetes/pkg/util/node" | ||||||
| 	taintutils "k8s.io/kubernetes/pkg/util/taints" | 	taintutils "k8s.io/kubernetes/pkg/util/taints" | ||||||
| ) | ) | ||||||
| @@ -337,7 +337,7 @@ func NewNodeLifecycleController( | |||||||
| 		}) | 		}) | ||||||
|  |  | ||||||
| 	if kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		metrics.RegisterMetricAndTrackRateLimiterUsage("node_lifecycle_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()) | 		ratelimiter.RegisterMetricAndTrackRateLimiterUsage("node_lifecycle_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()) | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	nc := &Controller{ | 	nc := &Controller{ | ||||||
|   | |||||||
| @@ -1,10 +1,4 @@ | |||||||
| package(default_visibility = ["//visibility:public"]) | load("@io_bazel_rules_go//go:def.bzl", "go_library", "go_test") | ||||||
|  |  | ||||||
| load( |  | ||||||
|     "@io_bazel_rules_go//go:def.bzl", |  | ||||||
|     "go_library", |  | ||||||
|     "go_test", |  | ||||||
| ) |  | ||||||
|  |  | ||||||
| go_library( | go_library( | ||||||
|     name = "go_default_library", |     name = "go_default_library", | ||||||
| @@ -13,8 +7,8 @@ go_library( | |||||||
|         "gc_controller.go", |         "gc_controller.go", | ||||||
|     ], |     ], | ||||||
|     importpath = "k8s.io/kubernetes/pkg/controller/podgc", |     importpath = "k8s.io/kubernetes/pkg/controller/podgc", | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/labels:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/labels:go_default_library", | ||||||
| @@ -25,6 +19,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/kubernetes:go_default_library", |         "//staging/src/k8s.io/client-go/kubernetes:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/listers/core/v1:go_default_library", |         "//staging/src/k8s.io/client-go/listers/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", |         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
| ) | ) | ||||||
| @@ -61,4 +56,5 @@ filegroup( | |||||||
|         "//pkg/controller/podgc/config:all-srcs", |         "//pkg/controller/podgc/config:all-srcs", | ||||||
|     ], |     ], | ||||||
|     tags = ["automanaged"], |     tags = ["automanaged"], | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
| ) | ) | ||||||
|   | |||||||
| @@ -31,7 +31,7 @@ import ( | |||||||
| 	clientset "k8s.io/client-go/kubernetes" | 	clientset "k8s.io/client-go/kubernetes" | ||||||
| 	corelisters "k8s.io/client-go/listers/core/v1" | 	corelisters "k8s.io/client-go/listers/core/v1" | ||||||
| 	"k8s.io/client-go/tools/cache" | 	"k8s.io/client-go/tools/cache" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
|  |  | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| ) | ) | ||||||
| @@ -52,7 +52,7 @@ type PodGCController struct { | |||||||
|  |  | ||||||
| func NewPodGC(kubeClient clientset.Interface, podInformer coreinformers.PodInformer, terminatedPodThreshold int) *PodGCController { | func NewPodGC(kubeClient clientset.Interface, podInformer coreinformers.PodInformer, terminatedPodThreshold int) *PodGCController { | ||||||
| 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		metrics.RegisterMetricAndTrackRateLimiterUsage("gc_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()) | 		ratelimiter.RegisterMetricAndTrackRateLimiterUsage("gc_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()) | ||||||
| 	} | 	} | ||||||
| 	gcc := &PodGCController{ | 	gcc := &PodGCController{ | ||||||
| 		kubeClient:             kubeClient, | 		kubeClient:             kubeClient, | ||||||
|   | |||||||
| @@ -17,7 +17,6 @@ go_library( | |||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/api/v1/pod:go_default_library", |         "//pkg/api/v1/pod:go_default_library", | ||||||
|         "//pkg/controller:go_default_library", |         "//pkg/controller:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/apps/v1:go_default_library", |         "//staging/src/k8s.io/api/apps/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", | ||||||
| @@ -37,6 +36,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", |         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/record:go_default_library", |         "//staging/src/k8s.io/client-go/tools/record:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|         "//vendor/k8s.io/utils/integer:go_default_library", |         "//vendor/k8s.io/utils/integer:go_default_library", | ||||||
|     ], |     ], | ||||||
|   | |||||||
| @@ -53,10 +53,10 @@ import ( | |||||||
| 	"k8s.io/client-go/tools/cache" | 	"k8s.io/client-go/tools/cache" | ||||||
| 	"k8s.io/client-go/tools/record" | 	"k8s.io/client-go/tools/record" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| 	podutil "k8s.io/kubernetes/pkg/api/v1/pod" | 	podutil "k8s.io/kubernetes/pkg/api/v1/pod" | ||||||
| 	"k8s.io/kubernetes/pkg/controller" | 	"k8s.io/kubernetes/pkg/controller" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| 	"k8s.io/utils/integer" | 	"k8s.io/utils/integer" | ||||||
| ) | ) | ||||||
|  |  | ||||||
| @@ -126,7 +126,7 @@ func NewReplicaSetController(rsInformer appsinformers.ReplicaSetInformer, podInf | |||||||
| func NewBaseController(rsInformer appsinformers.ReplicaSetInformer, podInformer coreinformers.PodInformer, kubeClient clientset.Interface, burstReplicas int, | func NewBaseController(rsInformer appsinformers.ReplicaSetInformer, podInformer coreinformers.PodInformer, kubeClient clientset.Interface, burstReplicas int, | ||||||
| 	gvk schema.GroupVersionKind, metricOwnerName, queueName string, podControl controller.PodControlInterface) *ReplicaSetController { | 	gvk schema.GroupVersionKind, metricOwnerName, queueName string, podControl controller.PodControlInterface) *ReplicaSetController { | ||||||
| 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		metrics.RegisterMetricAndTrackRateLimiterUsage(metricOwnerName, kubeClient.CoreV1().RESTClient().GetRateLimiter()) | 		ratelimiter.RegisterMetricAndTrackRateLimiterUsage(metricOwnerName, kubeClient.CoreV1().RESTClient().GetRateLimiter()) | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	rsc := &ReplicaSetController{ | 	rsc := &ReplicaSetController{ | ||||||
|   | |||||||
| @@ -1,10 +1,4 @@ | |||||||
| package(default_visibility = ["//visibility:public"]) | load("@io_bazel_rules_go//go:def.bzl", "go_library", "go_test") | ||||||
|  |  | ||||||
| load( |  | ||||||
|     "@io_bazel_rules_go//go:def.bzl", |  | ||||||
|     "go_library", |  | ||||||
|     "go_test", |  | ||||||
| ) |  | ||||||
|  |  | ||||||
| go_library( | go_library( | ||||||
|     name = "go_default_library", |     name = "go_default_library", | ||||||
| @@ -13,8 +7,8 @@ go_library( | |||||||
|         "route_controller.go", |         "route_controller.go", | ||||||
|     ], |     ], | ||||||
|     importpath = "k8s.io/kubernetes/pkg/controller/route", |     importpath = "k8s.io/kubernetes/pkg/controller/route", | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/labels:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/labels:go_default_library", | ||||||
| @@ -31,6 +25,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/util/retry:go_default_library", |         "//staging/src/k8s.io/client-go/util/retry:go_default_library", | ||||||
|         "//staging/src/k8s.io/cloud-provider:go_default_library", |         "//staging/src/k8s.io/cloud-provider:go_default_library", | ||||||
|         "//staging/src/k8s.io/cloud-provider/node/helpers:go_default_library", |         "//staging/src/k8s.io/cloud-provider/node/helpers:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
| ) | ) | ||||||
| @@ -63,4 +58,5 @@ filegroup( | |||||||
|     name = "all-srcs", |     name = "all-srcs", | ||||||
|     srcs = [":package-srcs"], |     srcs = [":package-srcs"], | ||||||
|     tags = ["automanaged"], |     tags = ["automanaged"], | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
| ) | ) | ||||||
|   | |||||||
| @@ -41,7 +41,7 @@ import ( | |||||||
| 	clientretry "k8s.io/client-go/util/retry" | 	clientretry "k8s.io/client-go/util/retry" | ||||||
| 	cloudprovider "k8s.io/cloud-provider" | 	cloudprovider "k8s.io/cloud-provider" | ||||||
| 	cloudnodeutil "k8s.io/cloud-provider/node/helpers" | 	cloudnodeutil "k8s.io/cloud-provider/node/helpers" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| ) | ) | ||||||
|  |  | ||||||
| const ( | const ( | ||||||
| @@ -69,7 +69,7 @@ type RouteController struct { | |||||||
|  |  | ||||||
| func New(routes cloudprovider.Routes, kubeClient clientset.Interface, nodeInformer coreinformers.NodeInformer, clusterName string, clusterCIDRs []*net.IPNet) *RouteController { | func New(routes cloudprovider.Routes, kubeClient clientset.Interface, nodeInformer coreinformers.NodeInformer, clusterName string, clusterCIDRs []*net.IPNet) *RouteController { | ||||||
| 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		metrics.RegisterMetricAndTrackRateLimiterUsage("route_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()) | 		ratelimiter.RegisterMetricAndTrackRateLimiterUsage("route_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()) | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	if len(clusterCIDRs) == 0 { | 	if len(clusterCIDRs) == 0 { | ||||||
|   | |||||||
| @@ -1,10 +1,4 @@ | |||||||
| package(default_visibility = ["//visibility:public"]) | load("@io_bazel_rules_go//go:def.bzl", "go_library", "go_test") | ||||||
|  |  | ||||||
| load( |  | ||||||
|     "@io_bazel_rules_go//go:def.bzl", |  | ||||||
|     "go_library", |  | ||||||
|     "go_test", |  | ||||||
| ) |  | ||||||
|  |  | ||||||
| go_library( | go_library( | ||||||
|     name = "go_default_library", |     name = "go_default_library", | ||||||
| @@ -14,9 +8,9 @@ go_library( | |||||||
|         "service_controller.go", |         "service_controller.go", | ||||||
|     ], |     ], | ||||||
|     importpath = "k8s.io/kubernetes/pkg/controller/service", |     importpath = "k8s.io/kubernetes/pkg/controller/service", | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/apis/core/v1/helper:go_default_library", |         "//pkg/apis/core/v1/helper:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/types:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/types:go_default_library", | ||||||
| @@ -35,6 +29,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|         "//staging/src/k8s.io/cloud-provider:go_default_library", |         "//staging/src/k8s.io/cloud-provider:go_default_library", | ||||||
|         "//staging/src/k8s.io/cloud-provider/service/helpers:go_default_library", |         "//staging/src/k8s.io/cloud-provider/service/helpers:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
| ) | ) | ||||||
| @@ -81,4 +76,5 @@ filegroup( | |||||||
|         "//pkg/controller/service/config:all-srcs", |         "//pkg/controller/service/config:all-srcs", | ||||||
|     ], |     ], | ||||||
|     tags = ["automanaged"], |     tags = ["automanaged"], | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
| ) | ) | ||||||
|   | |||||||
| @@ -40,9 +40,9 @@ import ( | |||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
| 	cloudprovider "k8s.io/cloud-provider" | 	cloudprovider "k8s.io/cloud-provider" | ||||||
| 	servicehelper "k8s.io/cloud-provider/service/helpers" | 	servicehelper "k8s.io/cloud-provider/service/helpers" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| 	v1helper "k8s.io/kubernetes/pkg/apis/core/v1/helper" | 	v1helper "k8s.io/kubernetes/pkg/apis/core/v1/helper" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| ) | ) | ||||||
|  |  | ||||||
| const ( | const ( | ||||||
| @@ -136,7 +136,7 @@ func New( | |||||||
| 	recorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "service-controller"}) | 	recorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "service-controller"}) | ||||||
|  |  | ||||||
| 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if kubeClient != nil && kubeClient.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		if err := metrics.RegisterMetricAndTrackRateLimiterUsage("service_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()); err != nil { | 		if err := ratelimiter.RegisterMetricAndTrackRateLimiterUsage("service_controller", kubeClient.CoreV1().RESTClient().GetRateLimiter()); err != nil { | ||||||
| 			return nil, err | 			return nil, err | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|   | |||||||
| @@ -18,7 +18,6 @@ go_library( | |||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/registry/core/secret:go_default_library", |         "//pkg/registry/core/secret:go_default_library", | ||||||
|         "//pkg/serviceaccount:go_default_library", |         "//pkg/serviceaccount:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library", | ||||||
| @@ -33,6 +32,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", |         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/retry:go_default_library", |         "//staging/src/k8s.io/client-go/util/retry:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
| ) | ) | ||||||
|   | |||||||
| @@ -31,8 +31,8 @@ import ( | |||||||
| 	corelisters "k8s.io/client-go/listers/core/v1" | 	corelisters "k8s.io/client-go/listers/core/v1" | ||||||
| 	"k8s.io/client-go/tools/cache" | 	"k8s.io/client-go/tools/cache" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| ) | ) | ||||||
|  |  | ||||||
| // ServiceAccountsControllerOptions contains options for running a ServiceAccountsController | // ServiceAccountsControllerOptions contains options for running a ServiceAccountsController | ||||||
| @@ -68,7 +68,7 @@ func NewServiceAccountsController(saInformer coreinformers.ServiceAccountInforme | |||||||
| 		queue:                   workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "serviceaccount"), | 		queue:                   workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "serviceaccount"), | ||||||
| 	} | 	} | ||||||
| 	if cl != nil && cl.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if cl != nil && cl.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		if err := metrics.RegisterMetricAndTrackRateLimiterUsage("serviceaccount_controller", cl.CoreV1().RESTClient().GetRateLimiter()); err != nil { | 		if err := ratelimiter.RegisterMetricAndTrackRateLimiterUsage("serviceaccount_controller", cl.CoreV1().RESTClient().GetRateLimiter()); err != nil { | ||||||
| 			return nil, err | 			return nil, err | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|   | |||||||
| @@ -35,10 +35,10 @@ import ( | |||||||
| 	"k8s.io/client-go/tools/cache" | 	"k8s.io/client-go/tools/cache" | ||||||
| 	clientretry "k8s.io/client-go/util/retry" | 	clientretry "k8s.io/client-go/util/retry" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| 	"k8s.io/kubernetes/pkg/registry/core/secret" | 	"k8s.io/kubernetes/pkg/registry/core/secret" | ||||||
| 	"k8s.io/kubernetes/pkg/serviceaccount" | 	"k8s.io/kubernetes/pkg/serviceaccount" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| ) | ) | ||||||
|  |  | ||||||
| // RemoveTokenBackoff is the recommended (empirical) retry interval for removing | // RemoveTokenBackoff is the recommended (empirical) retry interval for removing | ||||||
| @@ -86,7 +86,7 @@ func NewTokensController(serviceAccounts informers.ServiceAccountInformer, secre | |||||||
| 		maxRetries: maxRetries, | 		maxRetries: maxRetries, | ||||||
| 	} | 	} | ||||||
| 	if cl != nil && cl.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if cl != nil && cl.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		if err := metrics.RegisterMetricAndTrackRateLimiterUsage("serviceaccount_tokens_controller", cl.CoreV1().RESTClient().GetRateLimiter()); err != nil { | 		if err := ratelimiter.RegisterMetricAndTrackRateLimiterUsage("serviceaccount_tokens_controller", cl.CoreV1().RESTClient().GetRateLimiter()); err != nil { | ||||||
| 			return nil, err | 			return nil, err | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|   | |||||||
| @@ -8,7 +8,6 @@ go_library( | |||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/controller:go_default_library", |         "//pkg/controller:go_default_library", | ||||||
|         "//pkg/controller/job:go_default_library", |         "//pkg/controller/job:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//staging/src/k8s.io/api/batch/v1:go_default_library", |         "//staging/src/k8s.io/api/batch/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/api/errors:go_default_library", | ||||||
| @@ -23,6 +22,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", |         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/record:go_default_library", |         "//staging/src/k8s.io/client-go/tools/record:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//staging/src/k8s.io/kubectl/pkg/scheme:go_default_library", |         "//staging/src/k8s.io/kubectl/pkg/scheme:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
|   | |||||||
| @@ -36,10 +36,10 @@ import ( | |||||||
| 	"k8s.io/client-go/tools/cache" | 	"k8s.io/client-go/tools/cache" | ||||||
| 	"k8s.io/client-go/tools/record" | 	"k8s.io/client-go/tools/record" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/kubectl/pkg/scheme" | 	"k8s.io/kubectl/pkg/scheme" | ||||||
| 	"k8s.io/kubernetes/pkg/controller" | 	"k8s.io/kubernetes/pkg/controller" | ||||||
| 	jobutil "k8s.io/kubernetes/pkg/controller/job" | 	jobutil "k8s.io/kubernetes/pkg/controller/job" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| ) | ) | ||||||
|  |  | ||||||
| // Controller watches for changes of Jobs API objects. Triggered by Job creation | // Controller watches for changes of Jobs API objects. Triggered by Job creation | ||||||
| @@ -75,7 +75,7 @@ func New(jobInformer batchinformers.JobInformer, client clientset.Interface) *Co | |||||||
| 	eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: client.CoreV1().Events("")}) | 	eventBroadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: client.CoreV1().Events("")}) | ||||||
|  |  | ||||||
| 	if client != nil && client.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if client != nil && client.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		metrics.RegisterMetricAndTrackRateLimiterUsage("ttl_after_finished_controller", client.CoreV1().RESTClient().GetRateLimiter()) | 		ratelimiter.RegisterMetricAndTrackRateLimiterUsage("ttl_after_finished_controller", client.CoreV1().RESTClient().GetRateLimiter()) | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	tc := &Controller{ | 	tc := &Controller{ | ||||||
|   | |||||||
| @@ -7,7 +7,6 @@ go_library( | |||||||
|     visibility = ["//visibility:public"], |     visibility = ["//visibility:public"], | ||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/controller/volume/protectionutil:go_default_library", |         "//pkg/controller/volume/protectionutil:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//pkg/util/slice:go_default_library", |         "//pkg/util/slice:go_default_library", | ||||||
|         "//pkg/volume/util:go_default_library", |         "//pkg/volume/util:go_default_library", | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
| @@ -21,6 +20,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/listers/core/v1:go_default_library", |         "//staging/src/k8s.io/client-go/listers/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", |         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
| ) | ) | ||||||
|   | |||||||
| @@ -31,9 +31,9 @@ import ( | |||||||
| 	corelisters "k8s.io/client-go/listers/core/v1" | 	corelisters "k8s.io/client-go/listers/core/v1" | ||||||
| 	"k8s.io/client-go/tools/cache" | 	"k8s.io/client-go/tools/cache" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| 	"k8s.io/kubernetes/pkg/controller/volume/protectionutil" | 	"k8s.io/kubernetes/pkg/controller/volume/protectionutil" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| 	"k8s.io/kubernetes/pkg/util/slice" | 	"k8s.io/kubernetes/pkg/util/slice" | ||||||
| 	volumeutil "k8s.io/kubernetes/pkg/volume/util" | 	volumeutil "k8s.io/kubernetes/pkg/volume/util" | ||||||
| ) | ) | ||||||
| @@ -63,7 +63,7 @@ func NewPVCProtectionController(pvcInformer coreinformers.PersistentVolumeClaimI | |||||||
| 		storageObjectInUseProtectionEnabled: storageObjectInUseProtectionFeatureEnabled, | 		storageObjectInUseProtectionEnabled: storageObjectInUseProtectionFeatureEnabled, | ||||||
| 	} | 	} | ||||||
| 	if cl != nil && cl.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if cl != nil && cl.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		metrics.RegisterMetricAndTrackRateLimiterUsage("persistentvolumeclaim_protection_controller", cl.CoreV1().RESTClient().GetRateLimiter()) | 		ratelimiter.RegisterMetricAndTrackRateLimiterUsage("persistentvolumeclaim_protection_controller", cl.CoreV1().RESTClient().GetRateLimiter()) | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	e.pvcLister = pvcInformer.Lister() | 	e.pvcLister = pvcInformer.Lister() | ||||||
|   | |||||||
| @@ -7,7 +7,6 @@ go_library( | |||||||
|     visibility = ["//visibility:public"], |     visibility = ["//visibility:public"], | ||||||
|     deps = [ |     deps = [ | ||||||
|         "//pkg/controller/volume/protectionutil:go_default_library", |         "//pkg/controller/volume/protectionutil:go_default_library", | ||||||
|         "//pkg/util/metrics:go_default_library", |  | ||||||
|         "//pkg/util/slice:go_default_library", |         "//pkg/util/slice:go_default_library", | ||||||
|         "//pkg/volume/util:go_default_library", |         "//pkg/volume/util:go_default_library", | ||||||
|         "//staging/src/k8s.io/api/core/v1:go_default_library", |         "//staging/src/k8s.io/api/core/v1:go_default_library", | ||||||
| @@ -19,6 +18,7 @@ go_library( | |||||||
|         "//staging/src/k8s.io/client-go/listers/core/v1:go_default_library", |         "//staging/src/k8s.io/client-go/listers/core/v1:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", |         "//staging/src/k8s.io/client-go/tools/cache:go_default_library", | ||||||
|         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", |         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:go_default_library", | ||||||
|         "//vendor/k8s.io/klog:go_default_library", |         "//vendor/k8s.io/klog:go_default_library", | ||||||
|     ], |     ], | ||||||
| ) | ) | ||||||
|   | |||||||
| @@ -29,9 +29,9 @@ import ( | |||||||
| 	corelisters "k8s.io/client-go/listers/core/v1" | 	corelisters "k8s.io/client-go/listers/core/v1" | ||||||
| 	"k8s.io/client-go/tools/cache" | 	"k8s.io/client-go/tools/cache" | ||||||
| 	"k8s.io/client-go/util/workqueue" | 	"k8s.io/client-go/util/workqueue" | ||||||
|  | 	"k8s.io/component-base/metrics/prometheus/ratelimiter" | ||||||
| 	"k8s.io/klog" | 	"k8s.io/klog" | ||||||
| 	"k8s.io/kubernetes/pkg/controller/volume/protectionutil" | 	"k8s.io/kubernetes/pkg/controller/volume/protectionutil" | ||||||
| 	"k8s.io/kubernetes/pkg/util/metrics" |  | ||||||
| 	"k8s.io/kubernetes/pkg/util/slice" | 	"k8s.io/kubernetes/pkg/util/slice" | ||||||
| 	volumeutil "k8s.io/kubernetes/pkg/volume/util" | 	volumeutil "k8s.io/kubernetes/pkg/volume/util" | ||||||
| ) | ) | ||||||
| @@ -58,7 +58,7 @@ func NewPVProtectionController(pvInformer coreinformers.PersistentVolumeInformer | |||||||
| 		storageObjectInUseProtectionEnabled: storageObjectInUseProtectionFeatureEnabled, | 		storageObjectInUseProtectionEnabled: storageObjectInUseProtectionFeatureEnabled, | ||||||
| 	} | 	} | ||||||
| 	if cl != nil && cl.CoreV1().RESTClient().GetRateLimiter() != nil { | 	if cl != nil && cl.CoreV1().RESTClient().GetRateLimiter() != nil { | ||||||
| 		metrics.RegisterMetricAndTrackRateLimiterUsage("persistentvolume_protection_controller", cl.CoreV1().RESTClient().GetRateLimiter()) | 		ratelimiter.RegisterMetricAndTrackRateLimiterUsage("persistentvolume_protection_controller", cl.CoreV1().RESTClient().GetRateLimiter()) | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	e.pvLister = pvInformer.Lister() | 	e.pvLister = pvInformer.Lister() | ||||||
|   | |||||||
| @@ -31,7 +31,6 @@ filegroup( | |||||||
|         "//pkg/util/ipvs:all-srcs", |         "//pkg/util/ipvs:all-srcs", | ||||||
|         "//pkg/util/labels:all-srcs", |         "//pkg/util/labels:all-srcs", | ||||||
|         "//pkg/util/maps:all-srcs", |         "//pkg/util/maps:all-srcs", | ||||||
|         "//pkg/util/metrics:all-srcs", |  | ||||||
|         "//pkg/util/mount:all-srcs", |         "//pkg/util/mount:all-srcs", | ||||||
|         "//pkg/util/netsh:all-srcs", |         "//pkg/util/netsh:all-srcs", | ||||||
|         "//pkg/util/node:all-srcs", |         "//pkg/util/node:all-srcs", | ||||||
|   | |||||||
| @@ -1,11 +1,4 @@ | |||||||
| package(default_visibility = ["//visibility:public"]) | load("@io_bazel_rules_go//go:def.bzl", "go_library", "go_test") | ||||||
|  |  | ||||||
| load( |  | ||||||
|     "@io_bazel_rules_go//go:def.bzl", |  | ||||||
|     "go_library", |  | ||||||
|     "go_test", |  | ||||||
| ) |  | ||||||
| load("//staging/src/k8s.io/component-base/version:def.bzl", "version_x_defs") |  | ||||||
|  |  | ||||||
| go_library( | go_library( | ||||||
|     name = "go_default_library", |     name = "go_default_library", | ||||||
| @@ -25,6 +18,7 @@ go_library( | |||||||
|     ], |     ], | ||||||
|     importmap = "k8s.io/kubernetes/vendor/k8s.io/component-base/metrics", |     importmap = "k8s.io/kubernetes/vendor/k8s.io/component-base/metrics", | ||||||
|     importpath = "k8s.io/component-base/metrics", |     importpath = "k8s.io/component-base/metrics", | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
|     deps = [ |     deps = [ | ||||||
|         "//staging/src/k8s.io/apimachinery/pkg/version:go_default_library", |         "//staging/src/k8s.io/apimachinery/pkg/version:go_default_library", | ||||||
|         "//staging/src/k8s.io/component-base/version:go_default_library", |         "//staging/src/k8s.io/component-base/version:go_default_library", | ||||||
| @@ -70,9 +64,11 @@ filegroup( | |||||||
|         ":package-srcs", |         ":package-srcs", | ||||||
|         "//staging/src/k8s.io/component-base/metrics/legacyregistry:all-srcs", |         "//staging/src/k8s.io/component-base/metrics/legacyregistry:all-srcs", | ||||||
|         "//staging/src/k8s.io/component-base/metrics/prometheus/clientgo:all-srcs", |         "//staging/src/k8s.io/component-base/metrics/prometheus/clientgo:all-srcs", | ||||||
|  |         "//staging/src/k8s.io/component-base/metrics/prometheus/ratelimiter:all-srcs", | ||||||
|         "//staging/src/k8s.io/component-base/metrics/prometheus/restclient:all-srcs", |         "//staging/src/k8s.io/component-base/metrics/prometheus/restclient:all-srcs", | ||||||
|         "//staging/src/k8s.io/component-base/metrics/prometheus/version:all-srcs", |         "//staging/src/k8s.io/component-base/metrics/prometheus/version:all-srcs", | ||||||
|         "//staging/src/k8s.io/component-base/metrics/prometheus/workqueue:all-srcs", |         "//staging/src/k8s.io/component-base/metrics/prometheus/workqueue:all-srcs", | ||||||
|     ], |     ], | ||||||
|     tags = ["automanaged"], |     tags = ["automanaged"], | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
| ) | ) | ||||||
|   | |||||||
| @@ -1,15 +1,11 @@ | |||||||
| package(default_visibility = ["//visibility:public"]) | load("@io_bazel_rules_go//go:def.bzl", "go_library", "go_test") | ||||||
| 
 |  | ||||||
| load( |  | ||||||
|     "@io_bazel_rules_go//go:def.bzl", |  | ||||||
|     "go_library", |  | ||||||
|     "go_test", |  | ||||||
| ) |  | ||||||
| 
 | 
 | ||||||
| go_library( | go_library( | ||||||
|     name = "go_default_library", |     name = "go_default_library", | ||||||
|     srcs = ["util.go"], |     srcs = ["rate_limiter.go"], | ||||||
|     importpath = "k8s.io/kubernetes/pkg/util/metrics", |     importmap = "k8s.io/kubernetes/vendor/k8s.io/component-base/metrics/prometheus/ratelimiter", | ||||||
|  |     importpath = "k8s.io/component-base/metrics/prometheus/ratelimiter", | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
|     deps = [ |     deps = [ | ||||||
|         "//staging/src/k8s.io/client-go/util/flowcontrol:go_default_library", |         "//staging/src/k8s.io/client-go/util/flowcontrol:go_default_library", | ||||||
|         "//staging/src/k8s.io/component-base/metrics:go_default_library", |         "//staging/src/k8s.io/component-base/metrics:go_default_library", | ||||||
| @@ -19,11 +15,9 @@ go_library( | |||||||
| 
 | 
 | ||||||
| go_test( | go_test( | ||||||
|     name = "go_default_test", |     name = "go_default_test", | ||||||
|     srcs = ["util_test.go"], |     srcs = ["rate_limiter_test.go"], | ||||||
|     embed = [":go_default_library"], |     embed = [":go_default_library"], | ||||||
|     deps = [ |     deps = ["//staging/src/k8s.io/client-go/util/flowcontrol:go_default_library"], | ||||||
|         "//staging/src/k8s.io/client-go/util/flowcontrol:go_default_library", |  | ||||||
|     ], |  | ||||||
| ) | ) | ||||||
| 
 | 
 | ||||||
| filegroup( | filegroup( | ||||||
| @@ -37,4 +31,5 @@ filegroup( | |||||||
|     name = "all-srcs", |     name = "all-srcs", | ||||||
|     srcs = [":package-srcs"], |     srcs = [":package-srcs"], | ||||||
|     tags = ["automanaged"], |     tags = ["automanaged"], | ||||||
|  |     visibility = ["//visibility:public"], | ||||||
| ) | ) | ||||||
| @@ -14,7 +14,7 @@ See the License for the specific language governing permissions and | |||||||
| limitations under the License. | limitations under the License. | ||||||
| */ | */ | ||||||
| 
 | 
 | ||||||
| package metrics | package ratelimiter | ||||||
| 
 | 
 | ||||||
| import ( | import ( | ||||||
| 	"fmt" | 	"fmt" | ||||||
| @@ -14,7 +14,7 @@ See the License for the specific language governing permissions and | |||||||
| limitations under the License. | limitations under the License. | ||||||
| */ | */ | ||||||
| 
 | 
 | ||||||
| package metrics | package ratelimiter | ||||||
| 
 | 
 | ||||||
| import ( | import ( | ||||||
| 	"strings" | 	"strings" | ||||||
| @@ -92,7 +92,6 @@ | |||||||
| 				"k8s.io/kubernetes/pkg/util/filesystem", | 				"k8s.io/kubernetes/pkg/util/filesystem", | ||||||
| 				"k8s.io/kubernetes/pkg/util/hash", | 				"k8s.io/kubernetes/pkg/util/hash", | ||||||
| 				"k8s.io/kubernetes/pkg/util/labels", | 				"k8s.io/kubernetes/pkg/util/labels", | ||||||
| 				"k8s.io/kubernetes/pkg/util/metrics", |  | ||||||
| 				"k8s.io/kubernetes/pkg/util/mount", | 				"k8s.io/kubernetes/pkg/util/mount", | ||||||
| 				"k8s.io/kubernetes/pkg/util/node", | 				"k8s.io/kubernetes/pkg/util/node", | ||||||
| 				"k8s.io/kubernetes/pkg/util/parsers", | 				"k8s.io/kubernetes/pkg/util/parsers", | ||||||
|   | |||||||
							
								
								
									
										1
									
								
								vendor/modules.txt
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										1
									
								
								vendor/modules.txt
									
									
									
									
										vendored
									
									
								
							| @@ -1665,6 +1665,7 @@ k8s.io/component-base/metrics | |||||||
| k8s.io/component-base/metrics/legacyregistry | k8s.io/component-base/metrics/legacyregistry | ||||||
| k8s.io/component-base/metrics/prometheus/clientgo | k8s.io/component-base/metrics/prometheus/clientgo | ||||||
| k8s.io/component-base/metrics/prometheus/clientgo/leaderelection | k8s.io/component-base/metrics/prometheus/clientgo/leaderelection | ||||||
|  | k8s.io/component-base/metrics/prometheus/ratelimiter | ||||||
| k8s.io/component-base/metrics/prometheus/restclient | k8s.io/component-base/metrics/prometheus/restclient | ||||||
| k8s.io/component-base/metrics/prometheus/version | k8s.io/component-base/metrics/prometheus/version | ||||||
| k8s.io/component-base/metrics/prometheus/workqueue | k8s.io/component-base/metrics/prometheus/workqueue | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user
	 Yassine TIJANI
					Yassine TIJANI