Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for IsResourceRequest (0.41 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/selection_predicate_test.go

    			labelSelector: "",
    			fieldSelector: "",
    			indexLabels:   []string{},
    			indexFields:   []string{"metadata.namespace"},
    			ctx: request.WithRequestInfo(context.Background(), &request.RequestInfo{
    				IsResourceRequest: true,
    				Path:              "/api/v1/namespaces/default/pods",
    				Verb:              "list",
    				APIPrefix:         "api",
    				APIGroup:          "",
    				APIVersion:        "v1",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 30 10:39:09 UTC 2023
    - 8.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/caching_authorizer.go

    	GetUser() user.Info
    	GetVerb() string
    	IsReadOnly() bool
    	GetNamespace() string
    	GetResource() string
    	GetSubresource() string
    	GetName() string
    	GetAPIGroup() string
    	GetAPIVersion() string
    	IsResourceRequest() bool
    	GetPath() string
    })(nil)
    
    // The user info accessors known to cache key construction. If this fails to compile, the cache
    // implementation may need to be updated.
    var _ user.Info = (interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/filters/traces.go

    		otelhttp.WithTracerProvider(tp),
    		otelhttp.WithSpanNameFormatter(func(operation string, r *http.Request) string {
    			ctx := r.Context()
    			info, exist := request.RequestInfoFrom(ctx)
    			if !exist || !info.IsResourceRequest {
    				return r.Method
    			}
    			return getSpanNameFromRequestInfo(info, r)
    		}),
    	}
    	wrappedHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 15 01:42:42 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter_test.go

    	})
    	if err != nil {
    		t.Errorf("expected the controller to reconcile the priority level configuration object: %s, error: %s", plcObj.Name, err)
    	}
    
    	reqInfo := &request.RequestInfo{
    		IsResourceRequest: false,
    		Path:              "/foobar",
    		Verb:              "GET",
    	}
    	noteFn := func(fs *flowcontrol.FlowSchema, plc *flowcontrol.PriorityLevelConfiguration, fd string) {}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/rule.go

    }
    
    func matchesPolicyRule(digest RequestDigest, policyRule *flowcontrol.PolicyRulesWithSubjects) bool {
    	if !matchesASubject(digest.User, policyRule.Subjects) {
    		return false
    	}
    	if digest.RequestInfo.IsResourceRequest {
    		return matchesAResourceRule(digest.RequestInfo, policyRule.ResourceRules)
    	}
    	return matchesANonResourceRule(digest.RequestInfo, policyRule.NonResourceRules)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/util/proxy/proxy.go

    		// trim leading and trailing slashes. Then "/apis/group/version" requests are for discovery, so if we have exactly three
    		// segments that we are going to proxy, we have a discovery request.
    		if !requestInfo.IsResourceRequest && len(strings.Split(strings.Trim(requestInfo.Path, "/"), "/")) == 3 {
    			// discovery requests are used by kubectl and others to determine which resources a server has.  This is a cheap call that
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 19 00:36:22 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/borrowing_test.go

    			}
    
    			concIntegrators := make([]fq.Integrator, 2)
    			reqInfo := &request.RequestInfo{
    				IsResourceRequest: false,
    				Path:              "/foobar",
    				Verb:              "GET",
    			}
    			noteFn := func(fs *flowcontrol.FlowSchema, plc *flowcontrol.PriorityLevelConfiguration, fd string) {}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 9K bytes
    - Viewed (0)
Back to top