- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for IsResourceRequest (0.22 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)