Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 55 for GetSubresource (0.18 sec)

  1. pkg/volume/util/operationexecutor/operation_generator_test.go

    		return true, pv, nil
    	})
    	fakeKubeClient.AddReactor("patch", "persistentvolumeclaims", func(action core.Action) (bool, runtime.Object, error) {
    		if action.GetSubresource() == "status" {
    			return true, pvc, nil
    		}
    		return true, nil, fmt.Errorf("no reaction implemented for %s", action)
    	})
    
    	fakeRecorder := &record.FakeRecorder{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/registry/rest/update.go

    			obj,
    			old,
    			staticAttributes.GetKind(),
    			staticAttributes.GetNamespace(),
    			staticAttributes.GetName(),
    			staticAttributes.GetResource(),
    			staticAttributes.GetSubresource(),
    			staticAttributes.GetOperation(),
    			staticAttributes.GetOperationOptions(),
    			staticAttributes.IsDryRun(),
    			staticAttributes.GetUserInfo(),
    		)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 27 11:48:28 UTC 2022
    - 11.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go

    		attribute.String("configuration", invocation.Webhook.GetConfigurationName()),
    		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: Wed Aug 23 20:24:12 UTC 2023
    - 13K bytes
    - Viewed (0)
  4. pkg/controller/nodelifecycle/node_lifecycle_controller_test.go

    		}
    
    		podStatusUpdated := false
    		for _, action := range item.fakeNodeHandler.Actions() {
    			if action.GetVerb() == "update" && action.GetResource().Resource == "pods" && action.GetSubresource() == "status" {
    				podStatusUpdated = true
    			}
    		}
    		if podStatusUpdated != item.expectedPodStatusUpdate {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 03:26:45 UTC 2024
    - 119K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top