Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 139 for DeleteCollection (0.18 sec)

  1. cluster/gce/gci/audit_policy_test.go

    	at.testResources(request, kubelet, node, npd, npdSA, "update", "patch", nodeStatus, podStatus)
    
    	at.testResources(request, namespaceController, "deletecollection", pods, namespaces)
    
    	at.testResources(metadata, defaultSA, anonymous, npd, namespaceController, "get", "create", "update", secrets, configmaps, sysConfigmaps, tokenReviews)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Oct 30 06:23:50 UTC 2021
    - 9.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/filters/audit.go

    	// we will track latency in annotation only when the total latency
    	// of the given request exceeds 500ms, this is in keeping with the
    	// traces in rest/handlers for create, delete, update,
    	// get, list, and deletecollection.
    	const threshold = 500 * time.Millisecond
    	latency := ev.StageTimestamp.Time.Sub(ev.RequestReceivedTimestamp.Time)
    	if latency <= threshold {
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 8.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    			t.Errorf("Unexpected error: %v", err)
    		}
    	}
    
    	// Delete all pods.
    	deleted, err := registry.DeleteCollection(testContext, rest.ValidateAllObjectFunc, nil, &metainternalversion.ListOptions{})
    	if err != nil {
    		t.Fatalf("Unexpected error: %v", err)
    	}
    	deletedPods := deleted.(*example.PodList)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go

    			continue
    		}
    		// don't retry deleting the same namespace
    		deletedNamespaces.Insert(metadata.GetNamespace())
    		nsCtx := genericapirequest.WithNamespace(ctx, metadata.GetNamespace())
    		if _, err := crClient.DeleteCollection(nsCtx, rest.ValidateAllObjectFunc, nil, nil); err != nil {
    			deleteErrors = append(deleteErrors, err)
    			continue
    		}
    	}
    	if deleteError := utilerrors.NewAggregate(deleteErrors); deleteError != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/test/integration/conversion/conversion_test.go

    				case "delete":
    					err = clients["v1beta2"].Delete(context.TODO(), obj.GetName(), metav1.DeleteOptions{})
    				case "deletecollection":
    					err = clients["v1beta2"].DeleteCollection(context.TODO(), metav1.DeleteOptions{}, metav1.ListOptions{})
    				default:
    					t.Errorf("unknown verb %q", verb)
    				}
    
    				if err == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 06 05:32:34 UTC 2023
    - 47.1K bytes
    - Viewed (0)
  6. plugin/pkg/auth/authorizer/rbac/bootstrappolicy/policy.go

    // Label and Annotation are default maps of bootstrappolicy.
    var (
    	Write      = []string{"create", "update", "patch", "delete", "deletecollection"}
    	ReadWrite  = []string{"get", "list", "watch", "create", "update", "patch", "delete", "deletecollection"}
    	Read       = []string{"get", "list", "watch"}
    	ReadUpdate = []string{"get", "list", "watch", "update", "patch"}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 19:25:10 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go

    	case "delete":
    		allowsOptions := true
    		return handlers.DeleteResource(storage, allowsOptions, requestScope, r.admission)
    	case "deletecollection":
    		checkBody := true
    		return handlers.DeleteCollection(storage, checkBody, requestScope, r.admission)
    	default:
    		responsewriters.ErrorNegotiated(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 52.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/test/integration/basic_test.go

    				}
    
    			case <-time.After(5 * time.Second):
    				t.Errorf("missing watch event")
    			}
    		}
    
    		// Delete test
    		if err := noxuResourceClient.DeleteCollection(context.TODO(), *metav1.NewDeleteOptions(0), metav1.ListOptions{}); err != nil {
    			t.Fatal(err)
    		}
    	}
    }
    
    func TestInvalidCRUD(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 11:35:33 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  9. plugin/pkg/auth/authorizer/rbac/bootstrappolicy/testdata/controller-roles.yaml

        - ""
        resources:
        - namespaces/finalize
        - namespaces/status
        verbs:
        - update
      - apiGroups:
        - '*'
        resources:
        - '*'
        verbs:
        - delete
        - deletecollection
        - get
        - list
    - apiVersion: rbac.authorization.k8s.io/v1
      kind: ClusterRole
      metadata:
        annotations:
          rbac.authorization.kubernetes.io/autoupdate: "true"
        creationTimestamp: null
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/resources.go

    	if err != nil {
    		return err
    	}
    	if err = apiExtensionsClient.ApiextensionsV1().CustomResourceDefinitions().DeleteCollection(context.TODO(), metav1.DeleteOptions{}, deleteListOpts); err != nil {
    		return err
    	}
    	for _, crd := range list.Items {
    		for _, version := range servedV1Versions(&crd) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 19 02:01:40 UTC 2021
    - 21.4K bytes
    - Viewed (0)
Back to top