Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 82 for deleteOption (0.18 sec)

  1. cmd/erasure-encode_test.go

    	for i := 0; i < b.N; i++ {
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    			disk.Delete(context.Background(), "testbucket", "object", DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(size), DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. cmd/erasure-healing.go

    		// - Remove any remaining parts from outdated disks from before transition.
    		if partsMetadata[i].IsRemote() {
    			rmDataDir := partsMetadata[i].DataDir
    			disk.Delete(ctx, bucket, pathJoin(encodeDirObject(object), rmDataDir), DeleteOptions{
    				Immediate: true,
    				Recursive: true,
    			})
    		}
    
    		for i, v := range result.Before.Drives {
    			if v.Endpoint == disk.Endpoint().String() {
    				result.After.Drives[i].State = madmin.DriveStateOk
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  3. cmd/background-newdisks-heal-ops.go

    }
    
    // delete the tracker on disk.
    func (h *healingTracker) delete(ctx context.Context) error {
    	return h.disk.Delete(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename),
    		DeleteOptions{
    			Recursive: false,
    			Immediate: false,
    		},
    	)
    }
    
    func (h *healingTracker) isHealed(bucket string) bool {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    	for _, v := range h.HealedBuckets {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. cmd/erasure-object_test.go

    	}
    
    	for _, disk := range xl.getDisks() {
    		files, _ := disk.ListDir(ctx, "", bucket, object, -1)
    		for _, file := range files {
    			if file != "xl.meta" {
    				disk.Delete(ctx, bucket, pathJoin(object, file), DeleteOptions{
    					Recursive: true,
    					Immediate: false,
    				})
    			}
    		}
    	}
    
    	gr, err := xl.GetObjectNInfo(ctx, bucket, object, nil, nil, opts)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  5. istioctl/pkg/waypoint/waypoint.go

    	for _, name := range names {
    		wg.Add(1)
    		go func(name string) {
    			defer wg.Done()
    			if err := kubeClient.GatewayAPI().GatewayV1().Gateways(namespace).
    				Delete(context.Background(), name, metav1.DeleteOptions{}); err != nil {
    				if kerrors.IsNotFound(err) {
    					fmt.Fprintf(cmd.OutOrStdout(), "waypoint %v/%v not found\n", namespace, name)
    				} else {
    					mu.Lock()
    					multiErr = multierror.Append(multiErr, err)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  6. cmd/data-scanner.go

    	// - NoncurrentVersionExpiration is applicable
    	case lifecycle.DeleteVersionAction, lifecycle.DeleteAllVersionsAction, lifecycle.DelMarkerDeleteAllVersionsAction:
    		size = 0
    	case lifecycle.DeleteAction:
    		// On a non-versioned bucket, DeleteObject removes the only version permanently.
    		if !vc.PrefixEnabled(oi.Name) {
    			size = 0
    		}
    	}
    
    	applyLifecycleAction(lcEvt, lcEventSrc_Scanner, oi)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  7. cmd/storage-rest-server.go

    	if !s.checkID(p.DiskID) {
    		return np, grid.NewRemoteErr(errDiskNotFound)
    	}
    	volume := p.Volume
    	filePath := p.FilePath
    	forceDelMarker := p.ForceDelMarker
    
    	opts := DeleteOptions{}
    	err := s.getStorage().DeleteVersion(context.Background(), volume, filePath, p.FI, forceDelMarker, opts)
    	return np, grid.NewRemoteErr(err)
    }
    
    // ReadVersionHandlerWS read metadata of versionID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.5.md

      - [alpha] Cluster federation: Added support for DeleteOptions.OrphanDependents for federation resources. ([docs](http://kubernetes.io/docs/user-guide/federation/#cascading-deletion)) ([kubernetes/features#99](https://github.com/kubernetes/enhancements/issues/99))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 136.4K bytes
    - Viewed (0)
  9. cmd/erasure-metadata.go

    				continue
    			}
    			index := index
    			ng.Go(func() error {
    				if disks[index] == nil {
    					return errDiskNotFound
    				}
    				return disks[index].Delete(ctx, bucket, pathJoin(prefix, xlStorageFormatFile), DeleteOptions{
    					Recursive: true,
    				})
    			}, index)
    		}
    		ng.Wait()
    	}
    
    	return evalDisks(disks, mErrs), err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  10. cmd/xl-storage.go

    func (s *xlStorage) DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) (err error) {
    	if HasSuffix(path, SlashSeparator) {
    		return s.Delete(ctx, volume, path, DeleteOptions{
    			Recursive: false,
    			Immediate: false,
    		})
    	}
    
    	volumeDir, err := s.getVolDir(volume)
    	if err != nil {
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top