Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for DeleteVersion (5.46 sec)

  1. cmd/naughty-disk_test.go

    		return err
    	}
    	return d.disk.UpdateMetadata(ctx, volume, path, fi, opts)
    }
    
    func (d *naughtyDisk) DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) (err error) {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.DeleteVersion(ctx, volume, path, fi, forceDelMarker, opts)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  2. cmd/storage-interface.go

    	// WalkDir will walk a directory on disk and return a metacache stream on wr.
    	WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error
    
    	// Metadata operations
    	DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) error
    	DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    	}
    	defer done(&err)
    
    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.WriteAll(ctx, volume, path, b) })
    }
    
    func (p *xlStorageDiskIDCheck) DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricDeleteVersion, volume, path)
    	if err != nil {
    		return err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  4. cmd/xl-storage.go

    				removeAll(target)
    			}
    		}
    	}
    
    	return nil
    }
    
    // DeleteVersion - deletes FileInfo metadata for path at `xl.meta`. forceDelMarker
    // will force creating a new `xl.meta` to create a new delete marker
    func (s *xlStorage) DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) (err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    		g := errgroup.WithNErrs(len(disks))
    		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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  6. cmd/storage-rest-client.go

    		DiskID:     *client.diskID.Load(),
    		Volume:     volume,
    		FilePath:   path,
    		UpdateOpts: opts,
    		FI:         fi,
    	})
    	return toStorageErr(err)
    }
    
    func (client *storageRESTClient) DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) (err error) {
    	_, err = storageDeleteVersionRPC.Call(ctx, client.gridConn, &DeleteVersionHandlerParams{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v2.go

    		return x.versions[i].header.sortsBefore(x.versions[j].header)
    	})
    }
    
    // DeleteVersion deletes the version specified by version id.
    // returns to the caller which dataDir to delete, also
    // indicates if this is the last version.
    func (x *xlMetaV2) DeleteVersion(fi FileInfo) (string, error) {
    	// This is a situation where versionId is explicitly
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
  8. cmd/storage-rest-server.go

    		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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
Back to top