Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 2.6K 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
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 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 28 19:28:10 GMT 2024
    - Last Modified: Sun May 08 05:06:44 GMT 2022
    - 8.8K bytes
    - Viewed (0)
  4. 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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  5. 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()
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 3.5K 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"`
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K 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()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K 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{}))
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 26.2K bytes
    - Viewed (0)
  9. 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,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  10. cmd/object-multipart-handlers.go

    		return
    	}
    
    	completeMultiPartUpload := objectAPI.CompleteMultipartUpload
    
    	versioned := globalBucketVersioningSys.PrefixEnabled(bucket, object)
    	suspended := globalBucketVersioningSys.PrefixSuspended(bucket, object)
    	os := newObjSweeper(bucket, object).WithVersioning(versioned, suspended)
    	if !globalTierConfigMgr.Empty() {
    		// Get appropriate object info to identify the remote object to delete
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
Back to top