Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for RegisterMetrics (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top