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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 76.3K 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 3.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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  4. cmd/batch-handlers.go

    			time.Sleep(delay + time.Duration(rnd.Float64()*float64(delay)))
    			continue
    		}
    
    		break
    	}
    
    	return nil
    }
    
    // toObjectInfo converts minio.ObjectInfo to ObjectInfo
    func toObjectInfo(bucket, object string, objInfo miniogo.ObjectInfo) ObjectInfo {
    	tags, _ := tags.MapToObjectTags(objInfo.UserTags)
    	oi := ObjectInfo{
    		Bucket:                    bucket,
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 08 14:11:38 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  5. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 19K bytes
    - Viewed (1)
  6. cmd/bucket-replication.go

    	if err != 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 112K bytes
    - Viewed (1)
  7. cmd/global-heal.go

    			}
    		}
    
    		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)
    			switch {
    			case evt.Action.DeleteRestored(): // if restored copy has expired,delete it synchronously
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 08 09:22:13 GMT 2024
    - 14.2K bytes
    - Viewed (1)
  8. cmd/data-scanner.go

    		for _, fi := range fivs {
    			objectInfos = append(objectInfos, fi.ToObjectInfo(i.bucket, i.objectPath(), versioned))
    		}
    		return objectInfos, nil
    	}
    
    	overflowVersions := fivs[lim+1:]
    	// Retain the current version + most recent lim noncurrent versions
    	for _, fi := range fivs[:lim+1] {
    		objectInfos = append(objectInfos, fi.ToObjectInfo(i.bucket, i.objectPath(), versioned))
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 09:40:19 GMT 2024
    - 46.9K bytes
    - Viewed (0)
  9. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue May 31 09:57:57 GMT 2022
    - 7K bytes
    - Viewed (0)
  10. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.8K bytes
    - Viewed (0)
Back to top