- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for RegisterMetrics (0.22 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)