Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 30 for deleteOption (0.29 sec)

  1. pilot/pkg/config/kube/crdclient/types.gen.go

    	var deleteOptions metav1.DeleteOptions
    	if resourceVersion != nil {
    		deleteOptions.Preconditions = &metav1.Preconditions{ResourceVersion: resourceVersion}
    	}
    	switch typ {
    	case gvk.AuthorizationPolicy:
    		return c.Istio().SecurityV1beta1().AuthorizationPolicies(namespace).Delete(context.TODO(), name, deleteOptions)
    	case gvk.DestinationRule:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 12 17:37:32 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  2. plugin/pkg/admission/noderestriction/admission_test.go

    			podsGetter: existingPods,
    			attributes: admission.NewAttributesRecord(nil, nil, podKind, coremymirrorpod.Namespace, coremymirrorpod.Name, podResource, "", admission.Delete, &metav1.DeleteOptions{}, false, mynode),
    			err:        "",
    		},
    		{
    			name:       "forbid create of mirror pod status bound to self",
    			podsGetter: noExistingPods,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 73.2K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/lifecycle_test.go

    			objectName:     "foxdir/fooobject/foo.txt",
    			objectModTime:  time.Now().UTC().Add(-10 * 24 * time.Hour), // Created 10 days ago
    			expectedAction: DeleteAction,
    		},
    		// Too early to remove (test Days)
    		{
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  4. cmd/erasure-healing_test.go

    			t.Fatalf("Failed to getLatestFileInfo - %v", err)
    		}
    
    		for i := 0; i < nfi.Erasure.ParityBlocks; i++ {
    			erasureDisks[i].Delete(context.Background(), bucket, pathJoin(object, xlStorageFormatFile), DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    		}
    
    		// Try healing now, it should heal the content properly.
    		_, err = objLayer.HealObject(ctx, bucket, object, "", hopts)
    		if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go

    	return co
    }
    
    // This is a helper to convert UpdateOptions to DeleteOptions for the
    // delete-on-update path.
    func newDeleteOptionsFromUpdateOptions(in *metav1.UpdateOptions) *metav1.DeleteOptions {
    	do := &metav1.DeleteOptions{
    		DryRun: in.DryRun,
    	}
    	do.TypeMeta.SetGroupVersionKind(metav1.SchemeGroupVersion.WithKind("DeleteOptions"))
    	return do
    }
    
    // Get retrieves the item from storage.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 23:22:44 UTC 2024
    - 60.8K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/serviceregistry_test.go

    		}
    
    		expectServiceEndpoints(t, fx, expectedSvc, 80, instances)
    
    		_ = kube.CoreV1().Pods(pod.Namespace).Delete(context.TODO(), pod.Name, metav1.DeleteOptions{})
    		_ = kube.DiscoveryV1().EndpointSlices(pod.Namespace).Delete(context.TODO(), "service", metav1.DeleteOptions{})
    		_ = store.Delete(gvk.WorkloadEntry, workloadEntry.Name, workloadEntry.Namespace, nil)
    		expectServiceEndpoints(t, fx, expectedSvc, 80, []EndpointResponse{})
    	})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 51.2K bytes
    - Viewed (0)
  7. cmd/xl-storage_test.go

    			Recursive: false,
    			Immediate: false,
    		}); err != errFileAccessDenied {
    			t.Errorf("expected: %s, got: %s", errFileAccessDenied, err)
    		}
    	}
    
    	// TestXLStorage for delete on an removed disk.
    	// should fail with disk not found.
    	err = xlStorageDeletedStorage.Delete(context.Background(), "del-vol", "my-file", DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Apr 11 17:45:28 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go

    }
    
    // Test deleting an object.
    func (t *Tester) TestDelete(valid runtime.Object, createFn CreateFunc, getFn GetFunc, isNotFoundFn IsErrorFunc) {
    	dryRunOpts := metav1.DeleteOptions{DryRun: []string{metav1.DryRunAll}}
    	opts := metav1.DeleteOptions{}
    	t.testDeleteNonExist(valid.DeepCopyObject(), dryRunOpts)
    	t.testDeleteNonExist(valid.DeepCopyObject(), opts)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 55.8K bytes
    - Viewed (0)
  9. cmd/storage-datatypes_gen_test.go

    	}
    }
    
    func BenchmarkMarshalMsgDeleteOptions(b *testing.B) {
    	v := DeleteOptions{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgDeleteOptions(b *testing.B) {
    	v := DeleteOptions{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 62.6K bytes
    - Viewed (0)
  10. cmd/erasure-object.go

    	for index := range disks {
    		index := index
    		g.Go(func() error {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			return disks[index].DeleteVersion(ctx, bucket, object, fi, false, DeleteOptions{})
    		}, index)
    	}
    
    	rmDisks := make(map[string]string, len(disks))
    	for index, err := range g.Wait() {
    		var errStr, diskName string
    		if err != nil {
    			errStr = err.Error()
    		} else {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
Back to top