Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for tots (0.14 sec)

  1. cmd/data-scanner_test.go

    	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) {
    		t.Fatalf("Expected %d objects but got %d", len(wants), len(gots))
    	}
    
    	// Close expiry state's channel to inspect object versions enqueued for expiration
    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)
  2. cmd/bucket-replication.go

    		return &madmin.BucketTargets{}
    	}
    	topts := replication.ObjectOpts{Name: object}
    	tgtArns := cfg.FilterTargetArns(topts)
    	tgts = &madmin.BucketTargets{Targets: make([]madmin.BucketTarget, len(tgtArns))}
    	for i, tgtArn := range tgtArns {
    		tgt := globalBucketTargetSys.GetRemoteBucketTargetByArn(ctx, bucket, tgtArn)
    		tgts.Targets[i] = tgt
    	}
    
    	return tgts
    }
    
    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)
  3. cmd/xl-storage.go

    		if rcfg.HasActiveRules("", true) {
    			tgts, err := globalBucketTargetSys.ListBucketTargets(ctx, cache.Info.Name)
    			if err == nil {
    				cache.Info.replication = replicationConfig{
    					Config:  rcfg,
    					remotes: tgts,
    				}
    			}
    		}
    	}
    
    	vcfg, _ := globalBucketVersioningSys.Get(cache.Info.Name)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    	rcfg, _ := globalBucketObjectLockSys.Get(o.Bucket)
    	replCfg, _, _ := globalBucketMetadataSys.GetReplicationConfig(ctx, o.Bucket)
    	tgts, _ := globalBucketTargetSys.ListBucketTargets(ctx, o.Bucket)
    	o.Lifecycle = lc
    	o.Versioning = vc
    	o.Replication = replicationConfig{
    		Config:  replCfg,
    		remotes: tgts,
    	}
    	o.Retention = rcfg
    }
    
    // newMetacache constructs a new metacache from the options.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  5. cmd/erasure.go

    	// at any given point in time. This allows different buckets to be scanned
    	// in different order per erasure set, this wider spread is needed when
    	// there are lots of buckets with different order of objects in them.
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	permutes := r.Perm(len(buckets))
    	// Add new buckets first
    	for _, idx := range permutes {
    		b := buckets[idx]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
Back to top