- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 324 for epmetrics (0.21 sec)
-
cmd/metrics-realtime.go
aggr.Merge(&disk) } m.Aggregated.Disk = &aggr } if types.Contains(madmin.MetricsScanner) { metrics := globalScannerMetrics.report() m.Aggregated.Scanner = &metrics } if types.Contains(madmin.MetricsOS) { metrics := globalOSMetrics.report() m.Aggregated.OS = &metrics } if types.Contains(madmin.MetricsBatchJobs) { m.Aggregated.BatchJobs = globalBatchJobsMetrics.report(opts.jobID) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 05:16:24 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/routes/metrics.go
handlersmetrics "k8s.io/apiserver/pkg/endpoints/handlers/metrics" apimetrics "k8s.io/apiserver/pkg/endpoints/metrics" "k8s.io/apiserver/pkg/server/mux" cachermetrics "k8s.io/apiserver/pkg/storage/cacher/metrics" etcd3metrics "k8s.io/apiserver/pkg/storage/etcd3/metrics" flowcontrolmetrics "k8s.io/apiserver/pkg/util/flowcontrol/metrics" peerproxymetrics "k8s.io/apiserver/pkg/util/peerproxy/metrics" "k8s.io/component-base/metrics/legacyregistry" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 02:06:01 UTC 2023 - 1.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/metrics/metrics.go
evaluationTime *metrics.Histogram } func newCelMetrics() *CelMetrics { m := &CelMetrics{ compilationTime: metrics.NewHistogram(&metrics.HistogramOpts{ Namespace: namespace, Subsystem: subsystem, Name: "compilation_duration_seconds", Help: "CEL compilation time in seconds.", StabilityLevel: metrics.ALPHA, }),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 09 23:50:48 UTC 2022 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authorization/authorizerfactory/metrics.go
package authorizerfactory import ( "context" "sync" celmetrics "k8s.io/apiserver/pkg/authorization/cel" webhookmetrics "k8s.io/apiserver/plugin/pkg/authorizer/webhook/metrics" compbasemetrics "k8s.io/component-base/metrics" "k8s.io/component-base/metrics/legacyregistry" ) var registerMetrics sync.Once // RegisterMetrics registers authorizer metrics. func RegisterMetrics() { registerMetrics.Do(func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:01:15 UTC 2024 - 2.8K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/metrics.go
} func (m *defaultLeaderMetrics) leaderOff(name string) { if m == nil { return } m.leader.Off(name) } type noMetrics struct{} func (noMetrics) leaderOn(name string) {} func (noMetrics) leaderOff(name string) {} // MetricsProvider generates various metrics used by the leader election. type MetricsProvider interface { NewLeaderMetric() SwitchMetric } type noopMetricsProvider struct{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 11 16:58:48 UTC 2021 - 2.6K bytes - Viewed (0) -
cmd/metrics-v3-system-memory.go
// loadMemoryMetrics - `MetricsLoaderFn` for node memory metrics. func loadMemoryMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { memMetrics, err := c.memoryMetrics.Get() if err != nil { metricsLogIf(ctx, err) return err } m.Set(memTotal, float64(memMetrics.Total)) m.Set(memUsed, float64(memMetrics.Used)) usedPerc := float64(memMetrics.Used) * 100 / float64(memMetrics.Total) m.Set(memUsedPerc, usedPerc)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Apr 17 05:10:25 UTC 2024 - 2.2K bytes - Viewed (0) -
cmd/metrics-v3-cache.go
import ( "context" "sync" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/cachevalue" ) // metricsCache - cache for metrics. // // When serving metrics, this cache is passed to the MetricsLoaderFn. // // This cache is used for metrics that would result in network/storage calls. type metricsCache struct { dataUsageInfo *cachevalue.Cache[DataUsageInfo]
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 8.1K bytes - Viewed (0) -
cmd/metrics-v3-system-cpu.go
// loadCPUMetrics - `MetricsLoaderFn` for system CPU metrics. func loadCPUMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { cpuMetrics, _ := c.cpuMetrics.Get() if cpuMetrics.LoadStat != nil { m.Set(sysCPULoad, cpuMetrics.LoadStat.Load1) perc := cpuMetrics.LoadStat.Load1 * 100 / float64(cpuMetrics.CPUCount) m.Set(sysCPULoadPerc, math.Round(perc*100)/100) } ts := cpuMetrics.TimesStat
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Apr 23 23:56:12 UTC 2024 - 3K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/metrics/metrics.go
EndpointsDesired = metrics.NewGaugeVec( &metrics.GaugeOpts{ Subsystem: EndpointSliceMirroringSubsystem, Name: "endpoints_desired", Help: "Number of endpoints desired", StabilityLevel: metrics.ALPHA, }, []string{}, ) // NumEndpointSlices tracks the number of EndpointSlices in a cluster. NumEndpointSlices = metrics.NewGaugeVec( &metrics.GaugeOpts{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 06 19:43:35 UTC 2020 - 5.2K bytes - Viewed (0) -
pkg/serviceaccount/metrics.go
*/ package serviceaccount import ( "sync" "k8s.io/component-base/metrics" "k8s.io/component-base/metrics/legacyregistry" ) const kubeServiceAccountSubsystem = "serviceaccount" var ( // LegacyTokensTotal is the number of legacy tokens used against apiserver. legacyTokensTotal = metrics.NewCounter( &metrics.CounterOpts{ Subsystem: kubeServiceAccountSubsystem,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 03:52:06 UTC 2023 - 3.4K bytes - Viewed (0)