- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for recordDroppedRequest (0.22 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/dropped_requests_tracker_test.go
// Report single dropped requests in multiple PLs. // Validate if RetryAfter isn't bumped next second. for i := 0; i < 10; i++ { tracker.RecordDroppedRequest(fmt.Sprintf("pl-%d", i)) } fakeClock.Step(time.Second) for i := 0; i < 10; i++ { tracker.RecordDroppedRequest(fmt.Sprintf("pl-%d", i)) retryAfter := tracker.GetRetryAfter(fmt.Sprintf("pl-%d", i)) if retryAfter != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 26 13:50:25 UTC 2023 - 4.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/dropped_requests_tracker.go
// a history od dropped requests in the system for the purpose // of adjusting RetryAfter header to avoid system overload. type DroppedRequestsTracker interface { // RecordDroppedRequest records a request that was just // dropped from processing. RecordDroppedRequest(plName string) // GetRetryAfter returns the current suggested value of // RetryAfter value. GetRetryAfter(plName string) int64 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 26 13:50:25 UTC 2023 - 6.5K bytes - Viewed (0) -
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/server/filters/maxinflight.go
if group == user.SystemPrivilegedGroup { handler.ServeHTTP(w, r) return } } } // We need to split this data between buckets used for throttling. metrics.RecordDroppedRequest(r, requestInfo, metrics.APIServerComponent, isMutatingRequest) metrics.RecordRequestTermination(r, requestInfo, metrics.APIServerComponent, http.StatusTooManyRequests) tooManyRequests(r, w, retryAfter) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 11:34:15 UTC 2023 - 6.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics_test.go
Register() requestCounter.Reset() for _, test := range testCases { t.Run(test.desc, func(t *testing.T) { defer requestCounter.Reset() RecordDroppedRequest(test.request, test.requestInfo, APIServerComponent, test.isMutating) if err := testutil.GatherAndCompare(legacyregistry.DefaultGatherer, strings.NewReader(test.want), testedMetrics...); err != nil { t.Fatal(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 07:29:19 UTC 2023 - 14.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go
requestAbortsTotal.WithContext(req.Context()).WithLabelValues(reportedVerb, group, version, resource, subresource, scope).Inc() } // RecordDroppedRequest records that the request was rejected via http.TooManyRequests. func RecordDroppedRequest(req *http.Request, requestInfo *request.RequestInfo, component string, isMutatingRequest bool) { if requestInfo == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 07:29:19 UTC 2023 - 35K bytes - Viewed (0)