Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for fileInfoVersions (0.2 sec)

  1. cmd/metacache-entries.go

    			return nil, err
    		}
    		e.cached = &xl
    	}
    	return e.cached, nil
    }
    
    // fileInfoVersions returns the metadata as FileInfoVersions.
    // If entry is a directory it is returned as that.
    func (e *metaCacheEntry) fileInfoVersions(bucket string) (FileInfoVersions, error) {
    	if e.isDir() {
    		return FileInfoVersions{
    			Volume: bucket,
    			Name:   e.name,
    			Versions: []FileInfo{
    				{
    					Volume: bucket,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  2. cmd/storage-datatypes.go

    type FilesInfo struct {
    	Files       []FileInfo
    	IsTruncated bool
    }
    
    // Size returns size of all versions for the object 'Name'
    func (f FileInfoVersions) Size() (size int64) {
    	for _, v := range f.Versions {
    		size += v.Size
    	}
    	return size
    }
    
    // FileInfoVersions represent a list of versions for a given file.
    // The above means that any added/deleted fields are incompatible.
    //
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  3. cmd/metacache-server-pool.go

    		if o.Lifecycle != nil {
    			act := evalActionFromLifecycle(ctx, *o.Lifecycle, o.Retention, o.Replication.Config, objInfo).Action
    			skip = act.Delete() && !act.DeleteRestored()
    		}
    	}
    
    	fiv, err := obj.fileInfoVersions(o.Bucket)
    	if err != nil {
    		return
    	}
    
    	// Expire all versions if needed, if not attempt to queue for replication.
    	for _, version := range fiv.Versions {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  4. cmd/global-heal.go

    					return
    				}
    			}
    
    			// erasureObjects layer needs object names to be encoded
    			encodedEntryName := encodeDirObject(entry.name)
    
    			var result healEntryResult
    			fivs, err := entry.fileInfoVersions(bucket)
    			if err != nil {
    				_, err := er.HealObject(ctx, bucket, encodedEntryName, "",
    					madmin.HealOpts{
    						ScanMode: scanMode,
    						Remove:   healDeleteDangling,
    					})
    				if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  5. cmd/erasure-server-pool-decom.go

    			default:
    				return false
    			}
    		}
    
    		decommissionEntry := func(entry metaCacheEntry) {
    			defer wk.Give()
    
    			if entry.isDir() {
    				return
    			}
    
    			fivs, err := entry.fileInfoVersions(bi.Name)
    			if err != nil {
    				return
    			}
    
    			// We need a reversed order for decommissioning,
    			// to create the appropriate stack.
    			versionsSorter(fivs.Versions).reverse()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  6. cmd/storage-rest-client.go

    	})
    	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
    	}
    
    	values := make(url.Values)
    	values.Set(storageRESTVolume, volume)
    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/erasure-server-pool-rebalance.go

    			defer wk.Give()
    
    			if entry.isDir() {
    				return
    			}
    
    			// rebalance on poolIdx has reached its goal
    			if z.checkIfRebalanceDone(poolIdx) {
    				return
    			}
    
    			fivs, err := entry.fileInfoVersions(bucket)
    			if err != nil {
    				return
    			}
    
    			// We need a reversed order for rebalance,
    			// to create the appropriate stack.
    			versionsSorter(fivs.Versions).reverse()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  8. cmd/xl-storage-disk-id-check.go

    }
    
    // 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 := ""
    	if len(versions) > 0 {
    		path = versions[0].Name
    	}
    	errs = make([]error, len(versions))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  9. cmd/data-scanner.go

    					}
    
    					if entry.isDir() {
    						return
    					}
    
    					// We got an entry which we should be able to heal.
    					fiv, err := entry.fileInfoVersions(bucket)
    					if err != nil {
    						err := bgSeq.queueHealTask(healSource{
    							bucket:    bucket,
    							object:    entry.name,
    							versionID: "",
    						}, madmin.HealItemObject)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  10. cmd/storage-rest-server.go

    	volume := r.Form.Get(storageRESTVolume)
    	totalVersions, err := strconv.Atoi(r.Form.Get(storageRESTTotalVersions))
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    
    	versions := make([]FileInfoVersions, totalVersions)
    	decoder := msgpNewReader(r.Body)
    	defer readMsgpReaderPoolPut(decoder)
    	for i := 0; i < totalVersions; i++ {
    		dst := &versions[i]
    		if err := dst.DecodeMsg(decoder); err != nil {
    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