- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 634 for epmetrics (0.23 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go
}() } if !served { setResponseHeaders(classification, w) epmetrics.RecordDroppedRequest(r, requestInfo, epmetrics.APIServerComponent, isMutatingRequest) epmetrics.RecordRequestTermination(r, requestInfo, epmetrics.APIServerComponent, http.StatusTooManyRequests) h.droppedRequests.RecordDroppedRequest(classification.PriorityLevelName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 15.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/metrics.go
limitations under the License. */ package metrics import ( "context" "strconv" "strings" "sync" "time" epmetrics "k8s.io/apiserver/pkg/endpoints/metrics" apirequest "k8s.io/apiserver/pkg/endpoints/request" compbasemetrics "k8s.io/component-base/metrics" "k8s.io/component-base/metrics/legacyregistry" basemetricstestutil "k8s.io/component-base/metrics/testutil" ) const ( namespace = "apiserver"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 24 19:40:05 UTC 2023 - 25.6K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
for _, existingSlice := range existingSlices { slices.toDelete = append(slices.toDelete, existingSlice) } } } metrics.EndpointsAddedPerSync.WithLabelValues().Observe(float64(totals.added)) metrics.EndpointsUpdatedPerSync.WithLabelValues().Observe(float64(totals.updated)) metrics.EndpointsRemovedPerSync.WithLabelValues().Observe(float64(totals.removed))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
apifilters "k8s.io/apiserver/pkg/endpoints/filters" epmetrics "k8s.io/apiserver/pkg/endpoints/metrics" apirequest "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/apiserver/pkg/server/mux" utilflowcontrol "k8s.io/apiserver/pkg/util/flowcontrol" fq "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing" fcmetrics "k8s.io/apiserver/pkg/util/flowcontrol/metrics" fcrequest "k8s.io/apiserver/pkg/util/flowcontrol/request"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler.go
"k8s.io/apiserver/pkg/endpoints/handlers/responsewriters" epmetrics "k8s.io/apiserver/pkg/endpoints/metrics" apirequest "k8s.io/apiserver/pkg/endpoints/request" "k8s.io/apiserver/pkg/endpoints/responsewriter" "k8s.io/apiserver/pkg/reconcilers" "k8s.io/apiserver/pkg/storageversion" "k8s.io/apiserver/pkg/util/peerproxy/metrics" apiserverproxyutil "k8s.io/apiserver/pkg/util/proxy" "k8s.io/client-go/tools/cache"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 11.5K bytes - Viewed (0) -
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)