Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for newTestRequestInfoResolver (0.49 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/request/requestinfo_test.go

    		// api version identification
    		{"POST", "/apis/extensions/v1beta3/namespaces/other/pods", "create", "api", "extensions", "v1beta3", "other", "pods", "", "", []string{"pods"}},
    	}
    
    	resolver := newTestRequestInfoResolver()
    
    	for _, successCase := range successCases {
    		req, _ := http.NewRequest(successCase.method, successCase.url, nil)
    
    		apiRequestInfo, err := resolver.NewRequestInfo(req)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 15 12:19:21 UTC 2018
    - 11.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/filters/requestinfo_test.go

    limitations under the License.
    */
    
    package filters
    
    import (
    	"k8s.io/apimachinery/pkg/util/sets"
    	"k8s.io/apiserver/pkg/endpoints/request"
    )
    
    func newTestRequestInfoResolver() *request.RequestInfoFactory {
    	return &request.RequestInfoFactory{
    		APIPrefixes:          sets.NewString("api", "apis"),
    		GrouplessAPIPrefixes: sets.NewString("api"),
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 03 06:33:43 UTC 2017
    - 887 bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/filters/authorization_test.go

    		var handler http.Handler = http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
    			ctx := req.Context()
    			attribs, err = GetAuthorizerAttributes(ctx)
    		})
    		handler = WithRequestInfo(handler, newTestRequestInfoResolver())
    		handler.ServeHTTP(httptest.NewRecorder(), req)
    
    		if err != nil {
    			t.Errorf("%s: unexpected error: %v", k, err)
    		} else if !reflect.DeepEqual(attribs, tc.ExpectedAttributes) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/endpoints/filters/audit_test.go

    	ctx := audit.WithAuditContext(req.Context())
    	if user != nil {
    		ctx = request.WithUser(ctx, user)
    	}
    	if ae != nil {
    		ac := audit.AuditContextFrom(ctx)
    		ac.Event = *ae
    	}
    	if info, err := newTestRequestInfoResolver().NewRequestInfo(req); err == nil {
    		ctx = request.WithRequestInfo(ctx, info)
    	}
    	return req.WithContext(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 22.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/apiserver_test.go

    	}
    	b.StopTimer()
    }
    
    func newTestServer(handler http.Handler) *httptest.Server {
    	handler = genericapifilters.WithRequestInfo(handler, newTestRequestInfoResolver())
    	return httptest.NewServer(handler)
    }
    
    func newTestRequestInfoResolver() *request.RequestInfoFactory {
    	return &request.RequestInfoFactory{
    		APIPrefixes:          sets.NewString("api", "apis"),
    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