Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 132 for deleteSV (0.17 sec)

  1. docs/bucket/replication/delete-replication.sh

    aws configure set aws_secret_access_key minioadmin --profile minioadmin
    aws configure set default.region us-east-1 --profile minioadmin
    
    aws s3api --endpoint-url http://localhost:9001 --profile minioadmin delete-object --bucket testbucket --key dir/file --version-id "$versionId"
    
    ./mc ls -r --versions myminio1/testbucket >/tmp/myminio1.txt
    ./mc ls -r --versions myminio2/testbucket >/tmp/myminio2.txt
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat May 18 18:19:01 UTC 2024
    - 3K bytes
    - Viewed (0)
  2. pkg/kube/namespace/filter.go

    		DeleteFunc: func(ns *corev1.Namespace) {
    			f.lock.Lock()
    			defer f.lock.Unlock()
    			// No need to notify handlers for deletes. The namespace was deleted, so the object will be as well (and a delete could not de-select).
    			// Note that specifically for the edge case of a Namespace watcher that is filtering, this will ignore deletes we should
    			// otherwise send.
    			// See kclient.applyDynamicFilter for rationale.
    			f.namespaceDeletedLocked(ns.ObjectMeta)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 17:12:52 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  3. pilot/pkg/xds/deltatest.go

    	sotwRes model.Resources,
    	deltaRes model.Resources,
    	deleted model.DeletedResources,
    	usedDelta bool,
    	delta model.ResourceDelta,
    	incremental bool,
    ) {
    	current := con.proxy.GetWatchedResource(w.TypeUrl).LastResources
    	if current == nil {
    		log.Debugf("ADS:%s: resources initialized", v3.GetShortType(w.TypeUrl))
    		return
    	}
    	if deltaRes == nil && deleted == nil && len(sotwRes) == 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  4. cmd/api-datatypes.go

    	Location string   `xml:"LocationConstraint"`
    }
    
    // DeleteObjectsRequest - xml carrying the object key names which needs to be deleted.
    type DeleteObjectsRequest struct {
    	// Element to enable quiet mode for the request
    	Quiet bool
    	// List of objects to be deleted
    	Objects []ObjectToDelete `xml:"Object"`
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 14 07:26:50 UTC 2024
    - 3K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/watch/watch.go

    }
    
    // Modify sends a modify event.
    func (f *FakeWatcher) Modify(obj runtime.Object) {
    	f.result <- Event{Modified, obj}
    }
    
    // Delete sends a delete event.
    func (f *FakeWatcher) Delete(lastValue runtime.Object) {
    	f.result <- Event{Deleted, lastValue}
    }
    
    // Error sends an Error event.
    func (f *FakeWatcher) Error(errValue runtime.Object) {
    	f.result <- Event{Error, errValue}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 20:06:22 UTC 2024
    - 8.1K bytes
    - Viewed (1)
  6. android/guava-tests/test/com/google/common/io/IoTestCase.java

      @CanIgnoreReturnValue
      private boolean delete(File file) {
        if (file.isDirectory()) {
          File[] files = file.listFiles();
          if (files != null) {
            for (File f : files) {
              if (!delete(f)) {
                return false;
              }
            }
          }
        }
    
        if (!file.delete()) {
          logger.log(Level.WARNING, "couldn't delete file: {0}", new Object[] {file});
          return false;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 31 12:36:13 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  7. cmd/peer-s3-server.go

    	if err := listAllBuckets(ctx, localDrives, healBuckets, quorum); err != nil {
    		return nil, err
    	}
    
    	// include deleted buckets in listBuckets output
    	deletedBuckets := map[string]VolInfo{}
    
    	if opts.Deleted {
    		// lists all deleted buckets across drives.
    		if err := listDeletedBuckets(ctx, localDrives, deletedBuckets, quorum); err != nil {
    			return nil, err
    		}
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. subprojects/core/src/integTest/groovy/org/gradle/api/tasks/DeleteTaskIntegrationTest.groovy

                import org.gradle.api.internal.tasks.TaskPropertyUtils
    
                task clean(type: Delete) {
                    delete 'foo'
                    delete file('bar')
                    delete files('baz')
    
    
                    doLast {
                        def destroyablePaths = []
                        def propertyWalker = services.get(PropertyWalker)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 20 11:16:24 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  9. pkg/test/framework/components/istio/cleanup.go

    		i.installer.Dump(i.ctx)
    	}
    
    	if i.cfg.DeployIstio {
    		errG := multierror.Group{}
    		// Make sure to clean up primary clusters before remotes, or istiod will recreate some of the CMs that we delete
    		// in the remote clusters before it's deleted.
    		for _, c := range i.ctx.AllClusters().Primaries() {
    			i.cleanupCluster(c, &errG)
    		}
    		for _, c := range i.ctx.Clusters().Remotes() {
    			i.cleanupCluster(c, &errG)
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 5K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/serviceentry/store.go

    		ikey := makeInstanceKey(i)
    		s.instancesByHostAndPort.Delete(hostPort{ikey, i.ServicePort.Port})
    		oldInstances := s.instances[ikey][key]
    		delete(s.instances[ikey], key)
    		if len(s.instances[ikey]) == 0 {
    			delete(s.instances, ikey)
    		}
    		delete(s.ip2instance, i.Endpoint.Address)
    		// Cleanup stale IPs, if the IPs changed
    		for _, oi := range oldInstances {
    			s.instancesByHostAndPort.Delete(hostPort{ikey, oi.ServicePort.Port})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top