Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for DeleteVersions (0.23 sec)

  1. cmd/storage-interface.go

    	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
    	WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) error
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  2. cmd/naughty-disk_test.go

    }
    
    func (d *naughtyDisk) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error {
    	if err := d.calcError(); err != nil {
    		errs := make([]error, len(versions))
    		for i := range errs {
    			errs[i] = err
    		}
    		return errs
    	}
    	return d.disk.DeleteVersions(ctx, volume, versions, opts)
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    	return w.Run(func() error { return p.storage.Delete(ctx, volume, path, deleteOpts) })
    }
    
    // DeleteVersions deletes slice of versions, it can be same object
    // or multiple objects.
    func (p *xlStorageDiskIDCheck) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) (errs []error) {
    	// Merely for tracing storage
    	path := ""
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    		DiskID:   *client.diskID.Load(),
    		Volume:   volume,
    		FilePath: path,
    		Opts:     deleteOpts,
    	})
    	return toStorageErr(err)
    }
    
    // DeleteVersions - deletes list of specified versions if present
    func (client *storageRESTClient) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) (errs []error) {
    	if len(versions) == 0 {
    		return errs
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    	}
    
    	return s.deleteFile(volumeDir, pathJoin(volumeDir, path, xlStorageFormatFile), true, false)
    }
    
    // DeleteVersions deletes slice of versions, it can be same object
    // or multiple objects.
    func (s *xlStorage) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error {
    	errs := make([]error, len(versions))
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  6. cmd/xl-storage_test.go

    	for i := range versions[:10] {
    		fis[0].Versions = append(fis[0].Versions, FileInfo{Name: object, Volume: volume, VersionID: versions[i]})
    		deleted[i] = true
    	}
    	errs := xl.DeleteVersions(ctx, volume, fis, DeleteOptions{})
    	if errs[0] != nil {
    		t.Fatalf("expected nil error, got %v", errs[0])
    	}
    	checkVerExist(t)
    
    	// Delete them all... (some again)
    	fis[0].Versions = nil
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
  7. cmd/storage-rest-server.go

    	setEventStreamHeaders(w)
    	encoder := gob.NewEncoder(w)
    	done := keepHTTPResponseAlive(w)
    
    	opts := DeleteOptions{}
    	errs := s.getStorage().DeleteVersions(r.Context(), volume, versions, opts)
    	done(nil)
    	for idx := range versions {
    		if errs[idx] != nil {
    			dErrsResp.Errs[idx] = StorageErr(errs[idx].Error())
    		}
    	}
    	encoder.Encode(dErrsResp)
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    			delObjErrs[index] = make([]error, len(objects))
    			if disk == nil {
    				for i := range objects {
    					delObjErrs[index][i] = errDiskNotFound
    				}
    				return
    			}
    			errs := disk.DeleteVersions(ctx, bucket, dedupVersions, DeleteOptions{})
    			for i, err := range errs {
    				if err == nil {
    					continue
    				}
    				for _, v := range dedupVersions[i].Versions {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
Back to top