- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 228 for epmetrics (0.16 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/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) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/metrics/metrics.go
Help: "Time (in seconds) of inter arrival of transformation requests.", StabilityLevel: metrics.ALPHA, Buckets: metrics.ExponentialBuckets(60, 2, 10), }, []string{"transformation_type"}, ) // These metrics are made public to be used by unit tests. KMSOperationsLatencyMetric = metrics.NewHistogramVec( &metrics.HistogramOpts{ Namespace: namespace, Subsystem: subsystem,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 09 22:31:32 UTC 2023 - 12K bytes - Viewed (0) -
pkg/kubelet/metrics/metrics.go
StabilityLevel: metrics.ALPHA, }, ) NodeStartupDuration = metrics.NewGauge( &metrics.GaugeOpts{ Subsystem: KubeletSubsystem, Name: NodeStartupKey, Help: "Duration in seconds of node startup in total.", StabilityLevel: metrics.ALPHA, }, ) ImageGarbageCollectedTotal = metrics.NewCounterVec( &metrics.CounterOpts{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 15:13:25 UTC 2024 - 45.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/metrics/metrics.go
WebhookRejectionNoError WebhookRejectionErrorType = "no_error" ) var ( latencySummaryMaxAge = 5 * time.Hour // Metrics provides access to all admission metrics. Metrics = newAdmissionMetrics() ) // ObserverFunc is a func that emits metrics. type ObserverFunc func(ctx context.Context, elapsed time.Duration, rejected bool, attr admission.Attributes, stepType string, extraLabels ...string) const (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 17:01:40 UTC 2023 - 15.5K bytes - Viewed (0) -
cmd/metrics-v3.go
) // Collector paths. // // These are paths under the top-level /minio/metrics/v3 metrics endpoint. Each // of these paths returns a set of V3 metrics. // // Per-bucket metrics endpoints always start with /bucket and the bucket name is // appended to the path. e.g. if the collector path is /bucket/api, the endpoint // for the bucket "mybucket" would be /minio/metrics/v3/bucket/api/mybucket const (
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 09:36:25 UTC 2024 - 13.6K bytes - Viewed (0) -
cmd/metrics-v3-types.go
} return nil } } // MetricsGroup - represents a group of metrics. It includes a `MetricsLoaderFn` // function that provides a way to load the metrics from the system. The metrics // are cached and refreshed after a given timeout. // // For metrics with a `bucket` dimension, a list of buckets argument is required // to collect the metrics. // // It implements the prometheus.Collector interface for metric groups without a
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 07:41:18 UTC 2024 - 15.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/dispatcher.go
Binding: binding, PolicyDecision: decision, }) celmetrics.Metrics.ObserveRejection(ctx, decision.Elapsed, definition.Name, binding.Name, "active") case admissionregistrationv1.Audit: publishValidationFailureAnnotation(binding, i, decision, versionedAttr) celmetrics.Metrics.ObserveAudit(ctx, decision.Elapsed, definition.Name, binding.Name, "active")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 14.4K bytes - Viewed (0)