Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 48 for GetSubresource (0.29 sec)

  1. staging/src/k8s.io/apiserver/pkg/audit/request.go

    	if attribs.IsResourceRequest() {
    		ev.ObjectRef = &auditinternal.ObjectReference{
    			Namespace:   attribs.GetNamespace(),
    			Name:        attribs.GetName(),
    			Resource:    attribs.GetResource(),
    			Subresource: attribs.GetSubresource(),
    			APIGroup:    attribs.GetAPIGroup(),
    			APIVersion:  attribs.GetAPIVersion(),
    		}
    	}
    }
    
    // LogImpersonatedUser fills in the impersonated user attributes into an audit event.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 9K bytes
    - Viewed (0)
  2. plugin/pkg/admission/imagepolicy/admission.go

    	// Ignore all calls to subresources other than ephemeralcontainers or calls to resources other than pods.
    	subresource := attributes.GetSubresource()
    	if (subresource != "" && subresource != ephemeralcontainers) || attributes.GetResource().GroupResource() != api.Resource("pods") {
    		return nil
    	}
    
    	pod, ok := attributes.GetObject().(*api.Pod)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 02 06:05:06 UTC 2023
    - 9.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/registry/rest/create.go

    			obj,
    			staticAttributes.GetOldObject(),
    			staticAttributes.GetKind(),
    			staticAttributes.GetNamespace(),
    			name,
    			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
    - 9.1K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top