- Sort Score
- Result 10 results
- Languages All
Results 11 - 15 of 15 for RegisterMetrics (0.21 sec)
-
pkg/controller/endpointslice/endpointslice_controller.go
) *Controller { broadcaster := record.NewBroadcaster(record.WithContext(ctx)) recorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "endpoint-slice-controller"}) endpointslicemetrics.RegisterMetrics() c := &Controller{ client: client, // This is similar to the DefaultControllerRateLimiter, just with a // significantly higher default backoff (1s vs 5ms). This controller
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/kubeapiserver/options/authentication.go
if err != nil { return err } authInfo.Authenticator = authenticator if len(o.AuthenticationConfigFile) > 0 { authenticationconfigmetrics.RegisterMetrics() trackedAuthenticationConfigData := authenticatorConfig.AuthenticationConfigData var mu sync.Mutex go filesystem.WatchUntil( ctx, time.Minute, o.AuthenticationConfigFile, func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 22:40:22 UTC 2024 - 32.4K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler_test.go
} func handleErr(t *testing.T, err error, metricName string) { if err != nil { t.Errorf("Failed to get %s value, err: %v", metricName, err) } } func setupMetrics() { metrics.RegisterMetrics() metrics.NumEndpointSlices.Delete(map[string]string{}) metrics.DesiredEndpointSlices.Delete(map[string]string{}) metrics.EndpointsDesired.Delete(map[string]string{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 42.7K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "resource_claim"}, ), deletedObjects: newUIDCache(maxUIDCacheEntries), } metrics.RegisterMetrics() if _, err := podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { ec.enqueuePod(logger, obj, false) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
cmd/kube-proxy/app/server.go
logger.Info("Version info", "version", version.Get()) logger.Info("Golang settings", "GOGC", os.Getenv("GOGC"), "GOMAXPROCS", os.Getenv("GOMAXPROCS"), "GOTRACEBACK", os.Getenv("GOTRACEBACK")) proxymetrics.RegisterMetrics(s.Config.Mode) // TODO(vmarmol): Use container config for this. var oomAdjuster *oom.OOMAdjuster if s.Config.OOMScoreAdj != nil { oomAdjuster = oom.NewOOMAdjuster()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 46.8K bytes - Viewed (0)