Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 39 for IsResourceRequest (0.28 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/errors.go

    }
    
    func forbiddenMessage(attributes authorizer.Attributes) string {
    	username := ""
    	if user := attributes.GetUser(); user != nil {
    		username = user.GetName()
    	}
    
    	if !attributes.IsResourceRequest() {
    		return fmt.Sprintf("User %q cannot %s path %q", username, attributes.GetVerb(), attributes.GetPath())
    	}
    
    	resource := attributes.GetResource()
    	if subresource := attributes.GetSubresource(); len(subresource) > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 21 16:18:47 UTC 2018
    - 2.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/filters/authorization.go

    	if !found {
    		return nil, errors.New("no RequestInfo found in the context")
    	}
    
    	// Start with common attributes that apply to resource and non-resource requests
    	attribs.ResourceRequest = requestInfo.IsResourceRequest
    	attribs.Path = requestInfo.Path
    	attribs.Verb = requestInfo.Verb
    
    	attribs.APIGroup = requestInfo.APIGroup
    	attribs.APIVersion = requestInfo.APIVersion
    	attribs.Resource = requestInfo.Resource
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 20 13:35:55 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go

    	// However, we need to tweak it e.g. to differentiate GET from LIST.
    	reportedVerb := cleanVerb(CanonicalVerb(strings.ToUpper(req.Method), scope), "", req, requestInfo)
    
    	if requestInfo.IsResourceRequest {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 07:29:19 UTC 2023
    - 35K bytes
    - Viewed (0)
  4. pkg/registry/rbac/escalation_check.go

    	}
    
    	user, ok := genericapirequest.UserFrom(ctx)
    	if !ok {
    		return false
    	}
    
    	requestInfo, ok := genericapirequest.RequestInfoFrom(ctx)
    	if !ok {
    		return false
    	}
    
    	if !requestInfo.IsResourceRequest {
    		return false
    	}
    
    	requestResource := schema.GroupResource{Group: requestInfo.APIGroup, Resource: requestInfo.Resource}
    	if !roleResources[requestResource] {
    		return false
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 24 15:14:54 UTC 2019
    - 4.3K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. staging/src/k8s.io/apiserver/pkg/endpoints/filters/storageversion.go

    		if !found {
    			responsewriters.InternalError(w, req, errors.New("no RequestInfo found in the context"))
    			return
    		}
    		// Allow non-resource requests
    		if !requestInfo.IsResourceRequest {
    			handler.ServeHTTP(w, req)
    			return
    		}
    		// Allow read requests
    		if requestInfo.Verb == "get" || requestInfo.Verb == "list" || requestInfo.Verb == "watch" {
    			handler.ServeHTTP(w, req)
    			return
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 03 06:51:04 UTC 2023
    - 5K bytes
    - Viewed (0)
  8. 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)
  9. cluster/gce/gci/audit_policy_test.go

    				}
    				t.expectLevel(level, attrs)
    			}
    		}
    	}
    }
    
    func (t *auditTester) expectLevel(expected audit.Level, attrs authorizer.Attributes) {
    	obj := attrs.GetPath()
    	if attrs.IsResourceRequest() {
    		obj = attrs.GetResource()
    		if attrs.GetNamespace() != "" {
    			obj = obj + ":" + attrs.GetNamespace()
    		}
    	}
    	name := fmt.Sprintf("%s.%s.%s", attrs.GetUser().GetName(), attrs.GetVerb(), obj)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Oct 30 06:23:50 UTC 2021
    - 9.8K bytes
    - Viewed (0)
  10. 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