- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for GetRetryAfter (0.13 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)