Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for toObjectInfo (0.2 sec)

  1. cmd/erasure-object.go

    	if err != nil {
    		return oi, toObjectErr(err, srcBucket, srcObject)
    	}
    	if fi.Deleted {
    		if srcOpts.VersionID == "" {
    			return oi, toObjectErr(errFileNotFound, srcBucket, srcObject)
    		}
    		return fi.ToObjectInfo(srcBucket, srcObject, srcOpts.Versioned || srcOpts.VersionSuspended), toObjectErr(errMethodNotAllowed, srcBucket, srcObject)
    	}
    
    	filterOnlineDisksInplace(fi, metaArr, onlineDisks)
    
    	versionID := srcInfo.VersionID
    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)
  2. cmd/data-scanner_test.go

    			Size:        1 << 10,
    			NumVersions: 5,
    		}
    	}
    	versioned := vcfg.Status == "Enabled"
    	wants := make([]ObjectInfo, 2)
    	for i, fi := range fivs[:2] {
    		wants[i] = fi.ToObjectInfo(bucket, obj, versioned)
    	}
    	gots, err := item.applyNewerNoncurrentVersionLimit(context.TODO(), objAPI, fivs, es)
    	if err != nil {
    		t.Fatalf("Failed with err: %v", err)
    	}
    	if len(gots) != len(wants) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  3. cmd/metacache-server-pool.go

    	// for regular ListObjects() call only.
    	if !o.Versioned && !o.V1 {
    		fi, err := obj.fileInfo(o.Bucket)
    		if err != nil {
    			return
    		}
    		objInfo := fi.ToObjectInfo(o.Bucket, obj.name, versioned)
    		if o.Lifecycle != nil {
    			act := evalActionFromLifecycle(ctx, *o.Lifecycle, o.Retention, o.Replication.Config, objInfo).Action
    			skip = act.Delete() && !act.DeleteRestored()
    		}
    	}
    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/erasure-server-pool.go

    				if err != nil {
    					return
    				}
    				if opts.Filter != nil {
    					if opts.Filter(fi) {
    						if !send(fi.ToObjectInfo(bucket, fi.Name, vcfg != nil && vcfg.Versioned(fi.Name))) {
    							return
    						}
    					}
    				} else {
    					if !send(fi.ToObjectInfo(bucket, fi.Name, vcfg != nil && vcfg.Versioned(fi.Name))) {
    						return
    					}
    				}
    				continue
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  5. cmd/bucket-lifecycle_test.go

    		fi.TransitionStatus = lifecycle.TransitionComplete
    		fi.Metadata = tc.meta
    		if got := fi.IsRemote(); got != tc.remote {
    			t.Fatalf("Test %d.a: expected %v got %v", i+1, tc.remote, got)
    		}
    		oi := fi.ToObjectInfo("bucket", "object", false)
    		if got := oi.IsRemote(); got != tc.remote {
    			t.Fatalf("Test %d.b: expected %v got %v", i+1, tc.remote, got)
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue May 31 09:57:57 GMT 2022
    - 7K bytes
    - Viewed (0)
  6. cmd/erasure-metadata.go

    		len(fi.Erasure.Distribution) == (dataBlocks+parityBlocks))
    	return ((dataBlocks >= parityBlocks) &&
    		(dataBlocks > 0) && (parityBlocks >= 0) &&
    		correctIndexes)
    }
    
    // ToObjectInfo - Converts metadata to object info.
    func (fi FileInfo) ToObjectInfo(bucket, object string, versioned bool) ObjectInfo {
    	object = decodeDirObject(object)
    	versionID := fi.VersionID
    	if versioned && versionID == "" {
    		versionID = nullVersionID
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  7. cmd/bucket-replication.go

    	if err != nil || cfg == nil {
    		replLogOnceIf(ctx, err, "get-replication-config-"+bucket)
    		sendEvent(eventArgs{
    			EventName:  event.ObjectReplicationNotTracked,
    			BucketName: bucket,
    			Object:     ri.ToObjectInfo(),
    			UserAgent:  "Internal: [Replication]",
    			Host:       globalLocalNodeName,
    		})
    		return
    	}
    	tgtArns := cfg.FilterTargetArns(replication.ObjectOpts{
    		Name:     object,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  8. cmd/erasure-server-pool-rebalance.go

    		set := set
    
    		filterLifecycle := func(bucket, object string, fi FileInfo) bool {
    			if lc == nil {
    				return false
    			}
    			versioned := vc != nil && vc.Versioned(object)
    			objInfo := fi.ToObjectInfo(bucket, object, versioned)
    
    			evt := evalActionFromLifecycle(ctx, *lc, lr, rcfg, objInfo)
    			if evt.Action.Delete() {
    				globalExpiryState.enqueueByDays(objInfo, evt, lcEventSrc_Rebal)
    				return true
    			}
    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)
  9. cmd/object-api-datatypes.go

    	if o.IsLatest {
    		ts.NumObjects = 1
    	}
    	return ts
    }
    
    // ToObjectInfo converts a replication object info to a partial ObjectInfo
    // do not rely on this function to give you correct ObjectInfo, this
    // function is merely and optimization.
    func (ri ReplicateObjectInfo) ToObjectInfo() ObjectInfo {
    	return ObjectInfo{
    		Name:                       ri.Name,
    		Bucket:                     ri.Bucket,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  10. cmd/metacache-entries.go

    				}
    				afterV = ""
    			}
    
    			for _, version := range fiVersions {
    				versioned := vcfg != nil && vcfg.Versioned(entry.name)
    				versions = append(versions, version.ToObjectInfo(bucket, entry.name, versioned))
    			}
    
    			continue
    		}
    
    		if entry.isDir() {
    			if delimiter == "" {
    				continue
    			}
    			idx := strings.Index(strings.TrimPrefix(entry.name, prefix), delimiter)
    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)
Back to top