Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  2. 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()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
  3. 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)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    						return
    					}
    				}
    				continue
    			}
    			fivs, err := entry.fileInfoVersions(bucket)
    			if err != nil {
    				sendErr(err)
    				return
    			}
    
    			// Note: entry.fileInfoVersions returns versions sorted in reverse chronological order based on ModTime
    			if opts.VersionsSort == WalkVersionsSortAsc {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  5. 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()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    		// storage class only needs to be honored for
    		// Read() requests alone which we already do.
    		writeQuorums[i] = len(storageDisks)/2 + 1
    	}
    
    	versionsMap := make(map[string]FileInfoVersions, len(objects))
    	for i := range objects {
    		// Construct the FileInfo data that needs to be preserved on the disk.
    		vr := FileInfo{
    			Name:             objects[i].ObjectName,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  7. 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)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  8. 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 := range totalVersions {
    		dst := &versions[i]
    		if err := dst.DecodeMsg(decoder); err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  9. cmd/xl-storage_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	deleted[0] = true
    	checkVerExist(t)
    
    	// Delete 10 in bulk, including a non-existing.
    	fis := []FileInfoVersions{{Name: object, Volume: volume}}
    	for i := range versions[:10] {
    		fis[0].Versions = append(fis[0].Versions, FileInfo{Name: object, Volume: volume, VersionID: versions[i]})
    		deleted[i] = true
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 66K bytes
    - Viewed (0)
  10. cmd/xl-storage.go

    }
    
    // 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))
    
    	for i, fiv := range versions {
    		if contextCanceled(ctx) {
    			errs[i] = ctx.Err()
    			continue
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
Back to top