Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for RegisterMetrics (0.22 sec)

  1. pkg/scheduler/metrics/metrics.go

    		CacheSize,
    		unschedulableReasons,
    		PluginEvaluationTotal,
    	}
    )
    
    var registerMetrics sync.Once
    
    // Register all metrics.
    func Register() {
    	// Register the metrics.
    	registerMetrics.Do(func() {
    		RegisterMetrics(metricsList...)
    		volumebindingmetrics.RegisterVolumeSchedulingMetrics()
    	})
    }
    
    // RegisterMetrics registers a list of metrics.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 08:22:53 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/etcd3/metrics/metrics.go

    			StabilityLevel: compbasemetrics.ALPHA,
    		},
    		[]string{"resource"},
    	)
    )
    
    var registerMetrics sync.Once
    
    // Register all metrics.
    func Register() {
    	// Register the metrics.
    	registerMetrics.Do(func() {
    		legacyregistry.MustRegister(etcdRequestLatency)
    		legacyregistry.MustRegister(etcdRequestCounts)
    		legacyregistry.MustRegister(etcdRequestErrorCounts)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 21:15:32 UTC 2024
    - 11K bytes
    - Viewed (0)
  3. pkg/proxy/metrics/metrics.go

    )
    
    var registerMetricsOnce sync.Once
    
    // RegisterMetrics registers kube-proxy metrics.
    func RegisterMetrics(mode kubeproxyconfig.ProxyMode) {
    	registerMetricsOnce.Do(func() {
    		// Core kube-proxy metrics for all backends
    		legacyregistry.MustRegister(SyncProxyRulesLatency)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  4. pkg/proxy/healthcheck/healthcheck_test.go

    	}
    }
    
    type serverTest struct {
    	server      httpServer
    	url         url
    	tracking200 int
    	tracking503 int
    }
    
    func TestHealthzServer(t *testing.T) {
    	metrics.RegisterMetrics("")
    	listener := newFakeListener()
    	httpFactory := newFakeHTTPServerFactory()
    	fakeClock := testingclock.NewFakeClock(time.Now())
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go

    	utilruntime.Must(apiserverv1.AddToScheme(configScheme))
    	codecs = serializer.NewCodecFactory(configScheme, serializer.EnableStrict)
    	envelopemetrics.RegisterMetrics()
    	storagevalue.RegisterMetrics()
    	metrics.RegisterMetrics()
    }
    
    type kmsPluginHealthzResponse struct {
    	err      error
    	received time.Time
    }
    
    type kmsPluginProbe struct {
    	name         string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 16:56:39 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  6. pkg/controller/podgc/gc_controller.go

    		gcCheckPeriod:          gcCheckPeriod,
    		quarantineTime:         quarantineTime,
    	}
    
    	// Register prometheus metrics
    	metrics.RegisterMetrics()
    	return gcc
    }
    
    func (gcc *PodGCController) Run(ctx context.Context) {
    	logger := klog.FromContext(ctx)
    
    	defer utilruntime.HandleCrash()
    
    	logger.Info("Starting GC controller")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. pkg/controlplane/apiserver/config.go

    	additionalInitializers []admission.PluginInitializer,
    ) (
    	*Config,
    	[]admission.PluginInitializer,
    	error,
    ) {
    	proxyTransport := CreateProxyTransport()
    
    	opts.Metrics.Apply()
    	serviceaccount.RegisterMetrics()
    
    	config := &Config{
    		Generic: genericConfig,
    		Extra: Extra{
    			APIResourceConfigSource: storageFactory.APIResourceConfigSource,
    			StorageFactory:          storageFactory,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  8. pkg/kubelet/metrics/metrics.go

    			StabilityLevel: metrics.ALPHA,
    		},
    	)
    )
    
    var registerMetrics sync.Once
    
    // Register registers all metrics.
    func Register(collectors ...metrics.StableCollector) {
    	// Register the metrics.
    	registerMetrics.Do(func() {
    		legacyregistry.MustRegister(FirstNetworkPodStartSLIDuration)
    		legacyregistry.MustRegister(NodeName)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 15:13:25 UTC 2024
    - 45.6K bytes
    - Viewed (0)
  9. pkg/controller/resourceclaim/controller_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() {
    	ephemeralvolumemetrics.RegisterMetrics()
    	ephemeralvolumemetrics.ResourceClaimCreateAttempts.Reset()
    	ephemeralvolumemetrics.ResourceClaimCreateFailures.Reset()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 08:56:16 UTC 2024
    - 28.2K bytes
    - Viewed (0)
  10. pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go

    	logger := klog.FromContext(ctx)
    	broadcaster := record.NewBroadcaster(record.WithContext(ctx))
    	recorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "endpoint-slice-mirroring-controller"})
    
    	metrics.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: Mon May 06 23:18:31 UTC 2024
    - 20.1K bytes
    - Viewed (0)
Back to top