Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for IsSuspended (0.07 sec)

  1. cmd/erasure-server-pool.go

    	nSets := make([]int, len(z.serverPools))
    	g := errgroup.WithNErrs(len(z.serverPools))
    	for index := range z.serverPools {
    		index := index
    		// Skip suspended pools or pools participating in rebalance for any new
    		// I/O.
    		if z.IsSuspended(index) || z.IsPoolRebalancing(index) {
    			continue
    		}
    		pool := z.serverPools[index]
    		nSets[index] = pool.setCount
    		g.Go(func() error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    		if objects[i].VersionID == "" {
    			// MinIO extension to bucket version configuration
    			suspended := opts.VersionSuspended
    			versioned := opts.Versioned
    			if opts.PrefixEnabledFn != nil {
    				versioned = opts.PrefixEnabledFn(objects[i].ObjectName)
    			}
    			if versioned || suspended {
    				// Bucket is versioned and no version was explicitly
    				// mentioned for deletes, create a delete marker instead.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  3. cmd/bucket-handlers.go

    				}
    				continue
    			}
    		}
    
    		opts := ObjectOptions{
    			VersionID:        object.VersionID,
    			Versioned:        vc.PrefixEnabled(object.ObjectName),
    			VersionSuspended: vc.Suspended(),
    		}
    
    		if replicateDeletes || object.VersionID != "" && hasLockEnabled || !globalTierConfigMgr.Empty() {
    			if !globalTierConfigMgr.Empty() && object.VersionID == "" && opts.VersionSuspended {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  4. cmd/object-api-listobjects_test.go

    }
    
    func testDeleteObjectVersion(obj ObjectLayer, instanceType string, t1 TestErrHandler) {
    	t, _ := t1.(*testing.T)
    
    	testBuckets := []string{
    		"bucket-suspended-version",
    		"bucket-suspended-version-id",
    	}
    	for _, bucket := range testBuckets {
    		err := obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{
    			VersioningEnabled: true,
    		})
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 11:07:40 UTC 2024
    - 73.1K bytes
    - Viewed (0)
  5. cmd/admin-handlers-users.go

    				PrefixUsage:             prefixUsage,
    				Details: &madmin.BucketDetails{
    					Versioning:          globalBucketVersioningSys.Enabled(bucket.Name),
    					VersioningSuspended: globalBucketVersioningSys.Suspended(bucket.Name),
    					Replication:         rcfg != nil,
    					Locking:             lcfg.LockEnabled,
    					Quota:               quota,
    					Tagging:             tcfg,
    				},
    				Access: madmin.AccountAccess{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    	}
    
    	var reqVID string
    	if fi.VersionID == "" {
    		reqVID = nullVersionID
    	} else {
    		reqVID = fi.VersionID
    	}
    
    	// Empty fi.VersionID indicates that versioning is either
    	// suspended or disabled on this bucket. RenameData will replace
    	// the 'null' version. We add a free-version to track its tiered
    	// content for asynchronous deletion.
    	//
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top