Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 72 for GetSubresource (0.14 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission_test.go

    	if err == nil {
    		actions := ""
    		for _, action := range mockClient.Actions() {
    			actions = actions + action.GetVerb() + ":" + action.GetResource().Resource + ":" + action.GetSubresource() + ", "
    		}
    		t.Errorf("expected error returned from admission handler: %v", actions)
    	}
    
    	// verify create operations in the namespace cause an error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_node_status_test.go

    			assert.NoError(t, kubelet.updateNodeStatus(ctx))
    			actions := kubeClient.Actions()
    			require.Len(t, actions, 2)
    			require.True(t, actions[1].Matches("patch", "nodes"))
    			require.Equal(t, actions[1].GetSubresource(), "status")
    
    			updatedNode, err := applyNodeStatusPatch(&existingNode, actions[1].(core.PatchActionImpl).GetPatch())
    			assert.NoError(t, err)
    			for i, cond := range updatedNode.Status.Conditions {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  3. pkg/controller/deployment/deployment_controller_test.go

    			break
    		}
    
    		expectedAction := f.actions[i]
    		if !(expectedAction.Matches(action.GetVerb(), action.GetResource().Resource) && action.GetSubresource() == expectedAction.GetSubresource()) {
    			f.t.Errorf("Expected\n\t%#v\ngot\n\t%#v", expectedAction, action)
    			continue
    		}
    	}
    
    	if len(f.actions) > len(actions) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.5K bytes
    - Viewed (0)
  4. plugin/pkg/auth/authorizer/rbac/rbac_test.go

    func (d *defaultAttributes) GetNamespace() string    { return d.namespace }
    func (d *defaultAttributes) GetResource() string     { return d.resource }
    func (d *defaultAttributes) GetSubresource() string  { return d.subresource }
    func (d *defaultAttributes) GetName() string         { return "" }
    func (d *defaultAttributes) GetAPIGroup() string     { return d.apiGroup }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 24 15:14:54 UTC 2019
    - 21.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go

    		attribute.String("configuration", configurationName),
    		attribute.String("webhook", h.Name),
    		attribute.Stringer("resource", attr.GetResource()),
    		attribute.String("subresource", attr.GetSubresource()),
    		attribute.String("operation", string(attr.GetOperation())),
    		attribute.String("UID", string(uid)))
    	defer span.End(500 * time.Millisecond)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  6. pkg/controller/daemon/daemon_controller_test.go

    		if err != nil {
    			t.Fatal(err)
    		}
    
    		var updated *apps.DaemonSet
    		clientset.PrependReactor("update", "daemonsets", func(action core.Action) (handled bool, ret runtime.Object, err error) {
    			if action.GetSubresource() != "status" {
    				return false, nil, nil
    			}
    			if u, ok := action.(core.UpdateAction); ok {
    				updated = u.GetObject().(*apps.DaemonSet)
    			}
    			return false, nil, nil
    		})
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.4K bytes
    - Viewed (0)
  7. plugin/pkg/admission/limitranger/admission.go

    // Also ignores any call that has a subresource defined.
    func (d *DefaultLimitRangerActions) SupportsAttributes(a admission.Attributes) bool {
    	if a.GetSubresource() != "" {
    		return false
    	}
    
    	// Since containers and initContainers cannot currently be added, removed, or updated, it is unnecessary
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 13:04:39 UTC 2023
    - 25.8K bytes
    - Viewed (0)
  8. pkg/scheduler/schedule_one_test.go

    	var wg sync.WaitGroup
    	wg.Add(2 * len(pods))
    	bindings := make(map[string]string)
    	client.PrependReactor("create", "pods", func(action clienttesting.Action) (bool, runtime.Object, error) {
    		if action.GetSubresource() != "binding" {
    			return false, nil, nil
    		}
    		binding := action.(clienttesting.CreateAction).GetObject().(*v1.Binding)
    		bindings[binding.Name] = binding.Target.Name
    		wg.Done()
    		return true, binding, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  9. pkg/kubelet/status/status_manager_test.go

    	}
    	for i := 0; i < len(actions); i++ {
    		e := expectedActions[i]
    		a := actions[i]
    		if !a.Matches(e.GetVerb(), e.GetResource().Resource) || a.GetSubresource() != e.GetSubresource() {
    			t.Errorf("unexpected actions: %s", cmp.Diff(expectedActions, actions))
    		}
    	}
    }
    
    func verifyUpdates(t *testing.T, manager *manager, expectedUpdates int) {
    	t.Helper()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 68.1K bytes
    - Viewed (0)
  10. pkg/controller/resourcequota/resource_quota_controller_test.go

    		}
    
    		actionSet := sets.NewString()
    		for _, action := range kubeClient.Actions() {
    			actionSet.Insert(strings.Join([]string{action.GetVerb(), action.GetResource().Resource, action.GetSubresource()}, "-"))
    		}
    		if !actionSet.IsSuperset(testCase.expectedActionSet) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 16:29:33 UTC 2023
    - 42.6K bytes
    - Viewed (0)
Back to top