Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for WithRequestDeadline (0.33 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/filters/request_deadline.go

    // requestTimeoutMaximum specifies the default request timeout value.
    func WithRequestDeadline(handler http.Handler, sink audit.Sink, policy audit.PolicyRuleEvaluator, longRunning request.LongRunningRequestCheck,
    	negotiatedSerializer runtime.NegotiatedSerializer, requestTimeoutMaximum time.Duration) http.Handler {
    	return withRequestDeadline(handler, sink, policy, longRunning, negotiatedSerializer, requestTimeoutMaximum, clock.RealClock{})
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 05 21:12:12 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/filters/request_deadline_test.go

    				deadlineGot, hasDeadlineGot = deadline(req)
    			})
    
    			fakeSink := &fakeAuditSink{}
    			fakeRuleEvaluator := policy.NewFakePolicyRuleEvaluator(auditinternal.LevelRequestResponse, nil)
    			withDeadline := WithRequestDeadline(handler, fakeSink, fakeRuleEvaluator,
    				func(_ *http.Request, _ *request.RequestInfo) bool { return test.longRunning },
    				newSerializer(), requestTimeoutMaximum)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 14 23:04:34 UTC 2022
    - 16.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/config.go

    	handler = genericfilters.WithTimeoutForNonLongRunningRequests(handler, c.LongRunningFunc)
    
    	handler = genericapifilters.WithRequestDeadline(handler, c.AuditBackend, c.AuditPolicyRuleEvaluator,
    		c.LongRunningFunc, c.Serializer, c.RequestTimeout)
    	handler = genericfilters.WithWaitGroup(handler, c.LongRunningFunc, c.NonLongRunningRequestWaitGroup)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 47.7K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go

    	})
    
    	handler = WithTimeoutForNonLongRunningRequests(handler, longRunningRequestCheck)
    	// we don't have any request with invalid timeout, so leaving audit policy and sink nil.
    	handler = apifilters.WithRequestDeadline(handler, nil, nil, longRunningRequestCheck, nil, requestTimeout)
    	handler = apifilters.WithRequestInfo(handler, requestInfoFactory)
    	handler = WithPanicRecovery(handler, requestInfoFactory)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 52.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/apiserver_test.go

    	fakeRuleEvaluator := auditpolicy.NewFakePolicyRuleEvaluator(auditinternal.LevelRequestResponse, nil)
    	handler := genericapifilters.WithAudit(mux, auditSink, fakeRuleEvaluator, longRunningCheck)
    	handler = genericapifilters.WithRequestDeadline(handler, auditSink, fakeRuleEvaluator, longRunningCheck, codecs, 60*time.Second)
    	handler = genericapifilters.WithRequestInfo(handler, testRequestInfoResolver())
    	handler = genericapifilters.WithAuditInit(handler)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 20:15:22 UTC 2023
    - 158.7K bytes
    - Viewed (0)
Back to top