Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 34 for GetSubresource (0.28 sec)

  1. plugin/pkg/admission/noderestriction/admission.go

    	case podResource:
    		switch a.GetSubresource() {
    		case "":
    			return p.admitPod(nodeName, a)
    		case "status":
    			return p.admitPodStatus(nodeName, a)
    		case "eviction":
    			return p.admitPodEviction(nodeName, a)
    		default:
    			return admission.NewForbidden(a, fmt.Errorf("unexpected pod subresource %q, only 'status' and 'eviction' are allowed", a.GetSubresource()))
    		}
    
    	case nodeResource:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/filter.go

    	gvk := equivalentKind
    	gvr := equivalentGVR
    	subresource := attr.GetSubresource()
    
    	requestGVK := attr.GetKind()
    	requestGVR := attr.GetResource()
    	requestSubResource := attr.GetSubresource()
    
    	aUserInfo := attr.GetUserInfo()
    	var userInfo authenticationv1.UserInfo
    	if aUserInfo != nil {
    		userInfo = authenticationv1.UserInfo{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 24 14:46:11 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/cel/library/authz.go

    	GetNamespace() string
    	// GetResource is the name of the resource being requested.  This is not the kind.  For example: pods
    	GetResource() schema.GroupVersionResource
    	// GetSubresource is the name of the subresource being requested.  This is a different resource, scoped to the parent resource, but it may have a different kind.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 23 21:31:27 UTC 2023
    - 21.1K bytes
    - Viewed (0)
  4. pkg/controller/servicecidrs/servicecidrs_controller_test.go

    			t.Errorf("Expected action %d resource to be %s, got %s", i, resource, action.GetResource().Resource)
    		}
    		subresource := expected[i][2]
    		if action.GetSubresource() != subresource {
    			t.Errorf("Expected action %d subresource to be %s, got %s", i, subresource, action.GetSubresource())
    		}
    	}
    }
    
    func TestController_canDeleteCIDR(t *testing.T) {
    	tests := []struct {
    		name       string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 22K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook.go

    			Namespace:   attr.GetNamespace(),
    			Verb:        attr.GetVerb(),
    			Group:       attr.GetAPIGroup(),
    			Version:     attr.GetAPIVersion(),
    			Resource:    attr.GetResource(),
    			Subresource: attr.GetSubresource(),
    			Name:        attr.GetName(),
    		}
    	} else {
    		r.Spec.NonResourceAttributes = &authorizationv1.NonResourceAttributes{
    			Path: attr.GetPath(),
    			Verb: attr.GetVerb(),
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:01:15 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  6. pkg/kubelet/server/server.go

    			msg := fmt.Sprintf("Authorization error (user=%s, verb=%s, resource=%s, subresource=%s)", attrs.GetUser().GetName(), attrs.GetVerb(), attrs.GetResource(), attrs.GetSubresource())
    			resp.WriteErrorString(http.StatusInternalServerError, msg)
    			return
    		}
    		if decision != authorizer.DecisionAllow {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 40.1K bytes
    - Viewed (0)
  7. pkg/controller/volume/expand/expand_controller_test.go

    				return true, test.pv, nil
    			})
    		}
    		fakeKubeClient.AddReactor("patch", "persistentvolumeclaims", func(action coretesting.Action) (bool, runtime.Object, error) {
    			if action.GetSubresource() == "status" {
    				patchActionaction, _ := action.(coretesting.PatchAction)
    				pvc, err = applyPVCPatch(pvc, patchActionaction.GetPatch())
    				if err != nil {
    					return false, nil, err
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  8. plugin/pkg/admission/certificates/ctbattest/admission_test.go

    	admission.Attributes // nil panic if any other methods called
    }
    
    func (t *testAttributes) GetResource() schema.GroupVersionResource {
    	return t.resource.WithVersion("ignored")
    }
    
    func (t *testAttributes) GetSubresource() string {
    	return t.subresource
    }
    
    func (t *testAttributes) GetObject() runtime.Object {
    	return t.obj
    }
    
    func (t *testAttributes) GetOldObject() runtime.Object {
    	return t.oldObj
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  9. plugin/pkg/admission/runtimeclass/admission.go

    		}
    	}
    
    	return nil
    }
    
    func shouldIgnore(attributes admission.Attributes) bool {
    	// Ignore all calls to subresources or resources other than pods.
    	if len(attributes.GetSubresource()) != 0 || attributes.GetResource().GroupResource() != api.Resource("pods") {
    		return true
    	}
    
    	return false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 05 05:53:38 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  10. plugin/pkg/admission/resourcequota/admission_test.go

    	)
    	actionSet := sets.NewString()
    	for _, action := range kubeClient.Actions() {
    		actionSet.Insert(strings.Join([]string{action.GetVerb(), action.GetResource().Resource, action.GetSubresource()}, "-"))
    	}
    	if !actionSet.HasAll(expectedActionSet.List()...) {
    		t.Errorf("Expected actions:\n%v\n but got:\n%v\nDifference:\n%v", expectedActionSet, actionSet, expectedActionSet.Difference(actionSet))
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 84.1K bytes
    - Viewed (0)
Back to top