- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for GetRetryAfter (0.18 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/dropped_requests_tracker_test.go
// Record all droppeded requests and recompute retryAfter. for r := 0; r < step.droppedRequests; r++ { tracker.RecordDroppedRequest("pl") } if retryAfter := tracker.GetRetryAfter("pl"); retryAfter != step.retryAfter { t.Errorf("Unexpected retryAfter: %v, expected: %v", retryAfter, step.retryAfter) } } } func TestDroppedRequestsTrackerPLIndependent(t *testing.T) {
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
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 } // unixStat keeps a statistic how many requests were dropped within // a single second. type unixStat struct { unixTime int64 requests 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
// number, just return the truncated result and sleep the remainder server-side. tooManyRequests(r, w, strconv.Itoa(int(h.droppedRequests.GetRetryAfter(classification.PriorityLevelName)))) } } // WithPriorityAndFairness limits the number of in-flight // requests in a fine-grained way. func WithPriorityAndFairness( handler http.Handler,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 15.3K bytes - Viewed (0)