Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for IsResourceRequest (0.22 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/filters/longrunning.go

    	return func(r *http.Request, requestInfo *apirequest.RequestInfo) bool {
    		if longRunningVerbs.Has(requestInfo.Verb) {
    			return true
    		}
    		if requestInfo.IsResourceRequest && longRunningSubresources.Has(requestInfo.Subresource) {
    			return true
    		}
    		if !requestInfo.IsResourceRequest && strings.HasPrefix(requestInfo.Path, "/debug/pprof/") {
    			return true
    		}
    		return false
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jan 02 14:03:05 UTC 2018
    - 1.4K bytes
    - Viewed (0)
  2. 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)
  3. staging/src/k8s.io/apiserver/pkg/authorization/authorizer/interfaces.go

    	// GetAPIVersion returns the version of the group requested, if a request is for a REST object.
    	GetAPIVersion() string
    
    	// IsResourceRequest returns true for requests to API resources, like /api/v1/nodes,
    	// and false for non-resource endpoints like /api, /healthz
    	IsResourceRequest() bool
    
    	// GetPath returns the path of the request
    	GetPath() string
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 06 14:36:14 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  4. plugin/pkg/admission/certificates/approval/admission_test.go

    	}
    	if a.GetName() != f.allowedName {
    		return authorizer.DecisionDeny, fmt.Sprintf("unrecognised resource name '%s'", a.GetName()), nil
    	}
    	if !a.IsResourceRequest() {
    		return authorizer.DecisionDeny, fmt.Sprintf("unrecognised IsResourceRequest '%t'", a.IsResourceRequest()), nil
    	}
    	return f.decision, "", nil
    }
    
    type testAttributes struct {
    	resource    schema.GroupResource
    	subresource string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 27 15:50:14 UTC 2020
    - 6.3K bytes
    - Viewed (0)
  5. plugin/pkg/admission/certificates/signing/admission_test.go

    	}
    	if a.GetName() != f.allowedName {
    		return authorizer.DecisionDeny, fmt.Sprintf("unrecognised resource name '%s'", a.GetName()), nil
    	}
    	if !a.IsResourceRequest() {
    		return authorizer.DecisionDeny, fmt.Sprintf("unrecognised IsResourceRequest '%t'", a.IsResourceRequest()), nil
    	}
    	return f.decision, "", nil
    }
    
    type testAttributes struct {
    	resource    schema.GroupResource
    	subresource string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 28 16:20:40 UTC 2020
    - 8.9K bytes
    - Viewed (0)
  6. 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)
  7. staging/src/k8s.io/apiserver/pkg/authorization/path/path.go

    		} else {
    			paths.Insert(p)
    		}
    	}
    
    	return authorizer.AuthorizerFunc(func(ctx context.Context, a authorizer.Attributes) (authorizer.Decision, string, error) {
    		if a.IsResourceRequest() {
    			return authorizer.DecisionNoOpinion, "", nil
    		}
    
    		pth := strings.TrimPrefix(a.GetPath(), "/")
    		if paths.Has(pth) {
    			return authorizer.DecisionAllow, "", nil
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 09 13:47:19 UTC 2021
    - 1.9K bytes
    - Viewed (0)
  8. pkg/registry/rbac/clusterrole/policybased/storage_test.go

    		IsResourceRequest: true,
    		Verb:              "create",
    		APIGroup:          "rbac.authorization.k8s.io",
    		APIVersion:        "v1",
    		Resource:          "clusterroles",
    		Name:              "",
    	})
    	updateContext := request.WithRequestInfo(request.WithNamespace(context.TODO(), ""), &request.RequestInfo{
    		IsResourceRequest: true,
    		Verb:              "update",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 09 13:47:19 UTC 2021
    - 6.2K bytes
    - Viewed (0)
  9. plugin/pkg/auth/authorizer/rbac/rbac.go

    	// Build a detailed log of the denial.
    	// Make the whole block conditional so we don't do a lot of string-building we won't use.
    	if klogV := klog.V(5); klogV.Enabled() {
    		var operation string
    		if requestAttributes.IsResourceRequest() {
    			b := &bytes.Buffer{}
    			b.WriteString(`"`)
    			b.WriteString(requestAttributes.GetVerb())
    			b.WriteString(`" resource "`)
    			b.WriteString(requestAttributes.GetResource())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 24 10:13:50 UTC 2022
    - 7.8K bytes
    - Viewed (0)
  10. pkg/registry/rbac/role/policybased/storage_test.go

    		IsResourceRequest: true,
    		Verb:              "create",
    		APIGroup:          "rbac.authorization.k8s.io",
    		APIVersion:        "v1",
    		Namespace:         "myns",
    		Resource:          "roles",
    		Name:              "",
    	})
    	updateContext := request.WithRequestInfo(request.WithNamespace(context.TODO(), "myns"), &request.RequestInfo{
    		IsResourceRequest: true,
    		Verb:              "update",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 09 13:47:19 UTC 2021
    - 6.3K bytes
    - Viewed (0)
Back to top