Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for PrefixSuspended (0.24 sec)

  1. internal/bucket/versioning/versioning_test.go

    	for i, prefix := range testPrefixes {
    		if v.PrefixEnabled(prefix) || !v.PrefixSuspended(prefix) {
    			t.Fatalf("Test %d: Expected versioning to be excluded for %s", i+1, prefix)
    		}
    	}
    
    	// Test applicability for regular objects
    	if prefix := "prefix-1/obj-1"; !v.PrefixEnabled(prefix) || v.PrefixSuspended(prefix) {
    		t.Fatalf("Expected versioning to be enabled for %s", prefix)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 08 05:06:44 UTC 2022
    - 8.8K bytes
    - Viewed (0)
  2. internal/bucket/versioning/versioning.go

    }
    
    // Suspended - returns true if versioning is suspended
    func (v Versioning) Suspended() bool {
    	return v.Status == Suspended
    }
    
    // PrefixSuspended - returns true if versioning is suspended at the bucket level
    // or suspended on the given prefix.
    func (v Versioning) PrefixSuspended(prefix string) bool {
    	if v.Status == Suspended {
    		return true
    	}
    	if v.Status == Enabled {
    		if prefix == "" {
    			return false
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. cmd/bucket-versioning.go

    	}
    	return vc.Suspended()
    }
    
    // PrefixSuspended returns true if the given prefix matches an excluded prefix
    // pattern. This is part of a MinIO versioning configuration extension.
    func (sys *BucketVersioningSys) PrefixSuspended(bucket, prefix string) bool {
    	vc, err := sys.Get(bucket)
    	if err != nil {
    		logger.CriticalIf(GlobalContext, err)
    	}
    
    	return vc.PrefixSuspended(prefix)
    }
    
    // Get returns stored bucket policy
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 2.6K bytes
    - Viewed (0)
  4. cmd/post-policy-fan-out.go

    			}
    
    			objInfo, err := objectAPI.PutObject(ctx, bucket, req.Key, reader, ObjectOptions{
    				Versioned:        globalBucketVersioningSys.PrefixEnabled(bucket, req.Key),
    				VersionSuspended: globalBucketVersioningSys.PrefixSuspended(bucket, req.Key),
    				UserDefined:      userDefined,
    			})
    			if err != nil {
    				errs[idx] = err
    				return
    			}
    			objInfos[idx] = objInfo
    		}(i, req)
    	}
    	wg.Wait()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  5. cmd/object-api-options.go

    	opts.Tagging = r.Header.Get(xhttp.AmzTagDirective) == accessDirective
    	opts.Versioned = globalBucketVersioningSys.PrefixEnabled(bucket, object)
    	opts.VersionSuspended = globalBucketVersioningSys.PrefixSuspended(bucket, object)
    	return opts, nil
    }
    
    func getAndValidateAttributesOpts(ctx context.Context, w http.ResponseWriter, r *http.Request, bucket, object string) (opts ObjectOptions, valid bool) {
    	var argumentName string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 21:13:59 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  6. cmd/bucket-lifecycle.go

    		},
    		LifecycleAuditEvent: lae,
    		VersionID:           oi.VersionID,
    		Versioned:           globalBucketVersioningSys.PrefixEnabled(oi.Bucket, oi.Name),
    		VersionSuspended:    globalBucketVersioningSys.PrefixSuspended(oi.Bucket, oi.Name),
    		MTime:               oi.ModTime,
    	}
    	return objectAPI.TransitionObject(ctx, oi.Bucket, oi.Name, opts)
    }
    
    type auditTierOp struct {
    	Tier             string `json:"tier"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  7. cmd/batch-rotate.go

    		return errInvalidEncryptionParameters
    	}
    	versioned := globalBucketVersioningSys.PrefixEnabled(srcBucket, srcObject)
    	versionSuspended := globalBucketVersioningSys.PrefixSuspended(srcBucket, srcObject)
    
    	lock := api.NewNSLock(r.Bucket, objInfo.Name)
    	lkctx, err := lock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		return err
    	}
    	ctx = lkctx.Context()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  8. cmd/bucket-replication-utils.go

    				ObjectName: oi.Name,
    				VersionID:  oi.VersionID,
    			},
    		}, oi, ObjectOptions{
    			Versioned:        globalBucketVersioningSys.PrefixEnabled(oi.Bucket, oi.Name),
    			VersionSuspended: globalBucketVersioningSys.PrefixSuspended(oi.Bucket, oi.Name),
    		}, nil)
    	} else {
    		dsc = mustReplicate(GlobalContext, oi.Bucket, oi.Name, getMustReplicateOptions(userDefined, oi.UserTags, "", replication.HealReplicationType, ObjectOptions{}))
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  9. cmd/object-api-listobjects_test.go

    				int64(len(object.content)), hex.EncodeToString(md5Bytes[:]), ""), ObjectOptions{
    				Versioned:        globalBucketVersioningSys.PrefixEnabled(object.parentBucket, object.name),
    				VersionSuspended: globalBucketVersioningSys.PrefixSuspended(object.parentBucket, object.name),
    				UserDefined:      object.meta,
    			})
    		if err != nil {
    			t.Fatalf("%s : %s", instanceType, err)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 11:07:40 UTC 2024
    - 73.1K bytes
    - Viewed (0)
  10. cmd/bucket-replication.go

    			Host:       globalLocalNodeName,
    		})
    		return
    	}
    
    	versioned := globalBucketVersioningSys.PrefixEnabled(bucket, object)
    	versionSuspended := globalBucketVersioningSys.PrefixSuspended(bucket, object)
    
    	gr, err := objectAPI.GetObjectNInfo(ctx, bucket, object, nil, http.Header{}, ObjectOptions{
    		VersionID:          ri.VersionID,
    		Versioned:          versioned,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top