Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for PrefixEnabled (0.34 sec)

  1. cmd/bucket-versioning.go

    	if err != nil {
    		logger.CriticalIf(GlobalContext, err)
    	}
    	return vc.Enabled()
    }
    
    // PrefixEnabled returns true is versioning is enabled at bucket level and if
    // the given prefix doesn't match any excluded prefixes pattern. This is
    // part of a MinIO versioning configuration extension.
    func (sys *BucketVersioningSys) PrefixEnabled(bucket, prefix string) bool {
    	vc, err := sys.Get(bucket)
    	if err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 2.6K bytes
    - Viewed (0)
  2. internal/bucket/versioning/versioning.go

    // Versioned returns if 'prefix' has versioning enabled or suspended.
    func (v Versioning) Versioned(prefix string) bool {
    	return v.PrefixEnabled(prefix) || v.PrefixSuspended(prefix)
    }
    
    // PrefixEnabled - returns true if versioning is enabled at the bucket and given
    // prefix, false otherwise.
    func (v Versioning) PrefixEnabled(prefix string) bool {
    	if v.Status != Enabled {
    		return false
    	}
    
    	if prefix == "" {
    		return true
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 4.6K bytes
    - Viewed (0)
  3. 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)
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun May 08 05:06:44 GMT 2022
    - 8.8K bytes
    - Viewed (0)
  4. cmd/object-api-options.go

    	if err != nil {
    		return opts, err
    	}
    	opts.CheckDMReplicationReady = replReadyCheck
    
    	opts.Tagging = r.Header.Get(xhttp.AmzTagDirective) == accessDirective
    	opts.Versioned = globalBucketVersioningSys.PrefixEnabled(bucket, object)
    	opts.VersionSuspended = globalBucketVersioningSys.PrefixSuspended(bucket, object)
    	return opts, nil
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  5. cmd/bucket-lifecycle.go

    	traceFn := globalLifecycleSys.trace(*oi)
    	opts := ObjectOptions{
    		Versioned:  globalBucketVersioningSys.PrefixEnabled(oi.Bucket, oi.Name),
    		Expiration: ExpirationOptions{Expire: true},
    	}
    	if lcEvent.Action.DeleteVersioned() {
    		opts.VersionID = oi.VersionID
    	}
    	tags := newLifecycleAuditEvent(src, lcEvent).Tags()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  6. cmd/post-policy-fan-out.go

    				if err != nil {
    					errs[idx] = err
    					return
    				}
    			}
    
    			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
    			}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  7. cmd/object-handlers-common.go

    		} else {
    			remaining = nil
    		}
    		vc, _ := globalBucketVersioningSys.Get(bucket)
    		deletedObjs, errs := o.DeleteObjects(ctx, bucket, toDel, ObjectOptions{
    			PrefixEnabledFn:  vc.PrefixEnabled,
    			VersionSuspended: vc.Suspended(),
    		})
    
    		for i, dobj := range deletedObjs {
    			oi := ObjectInfo{
    				Bucket:    bucket,
    				Name:      dobj.ObjectName,
    				VersionID: dobj.VersionID,
    			}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Apr 09 08:17:49 GMT 2024
    - 14.6K bytes
    - Viewed (0)
  8. cmd/batch-rotate.go

    	}
    	if sseKMS && r.Encryption.Type == sses3 { // previously encrypted with sse-kms, now sse-s3 disallowed
    		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)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  9. cmd/object-api-listobjects_test.go

    			Versioned:   globalBucketVersioningSys.PrefixEnabled(object.parentBucket, object.name),
    			UserDefined: object.meta,
    		})
    		if err != nil {
    			t.Fatalf("%s : %s", instanceType, err.Error())
    		}
    		if object.addDeleteMarker {
    			oi, err := obj.DeleteObject(context.Background(), object.parentBucket, object.name, ObjectOptions{
    				Versioned: globalBucketVersioningSys.PrefixEnabled(object.parentBucket, object.name),
    			})
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  10. cmd/object-multipart-handlers.go

    	gr, err := getObjectNInfo(ctx, srcBucket, srcObject, rs, r.Header, getOpts)
    	if err != nil {
    		if isErrPreconditionFailed(err) {
    			return
    		}
    		if globalBucketVersioningSys.PrefixEnabled(srcBucket, srcObject) && gr != nil {
    			// Versioning enabled quite possibly object is deleted might be delete-marker
    			// if present set the headers, no idea why AWS S3 sets these headers.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
Back to top