Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for newObjSweeper (0.6 sec)

  1. cmd/tier-sweeper.go

    	TransitionStatus    string
    	TransitionTier      string
    	TransitionVersionID string
    	RemoteObject        string
    }
    
    // newObjSweeper returns an objSweeper for a given bucket and object.
    // It initializes the versioning information using bucket name.
    func newObjSweeper(bucket, object string) *objSweeper {
    	return &objSweeper{
    		Object: object,
    		Bucket: bucket,
    	}
    }
    
    // WithVersion sets the version ID from v
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 4.7K bytes
    - Viewed (0)
  2. cmd/object-handlers.go

    			return
    		}
    		objInfo.UserDefined = cloneMSS(opts.UserMetadata)
    		objInfo.ETag = remoteObjInfo.ETag
    		objInfo.ModTime = remoteObjInfo.LastModified
    	} else {
    		os = newObjSweeper(dstBucket, dstObject).WithVersioning(dstOpts.Versioned, dstOpts.VersionSuspended)
    		// Get appropriate object info to identify the remote object to delete
    		if !srcInfo.metadataOnly {
    			goiOpts := os.GetOpts()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 125K bytes
    - Viewed (0)
  3. cmd/object-multipart-handlers.go

    	completeMultiPartUpload := objectAPI.CompleteMultipartUpload
    
    	versioned := globalBucketVersioningSys.PrefixEnabled(bucket, object)
    	suspended := globalBucketVersioningSys.PrefixSuspended(bucket, object)
    	os := newObjSweeper(bucket, object).WithVersioning(versioned, suspended)
    	if !globalTierConfigMgr.Empty() {
    		// Get appropriate object info to identify the remote object to delete
    		goiOpts := os.GetOpts()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  4. cmd/bucket-handlers.go

    				opts.VersionID = nullVersionID
    			}
    			goi, gerr = getObjectInfoFn(ctx, bucket, object.ObjectName, opts)
    		}
    
    		if !globalTierConfigMgr.Empty() {
    			oss[index] = newObjSweeper(bucket, object.ObjectName).WithVersion(opts.VersionID).WithVersioning(opts.Versioned, opts.VersionSuspended)
    			oss[index].SetTransitionState(goi.TransitionedObject)
    		}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
Back to top