Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for recordDroppedRequest (0.3 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top