Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for getReplicationConfig (0.36 sec)

  1. cmd/erasure-server-pool-rebalance.go

    			return err
    		}
    
    		// Check if bucket is object locked.
    		lr, err = globalBucketObjectLockSys.Get(bucket)
    		if err != nil {
    			return err
    		}
    
    		rcfg, err = getReplicationConfig(ctx, bucket)
    		if err != nil {
    			return err
    		}
    	}
    
    	pool := z.serverPools[poolIdx]
    
    	const envRebalanceWorkers = "_MINIO_REBALANCE_WORKERS"
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  2. cmd/metacache-set.go

    	vc, _ := globalBucketVersioningSys.Get(o.Bucket)
    
    	// Check if bucket is object locked.
    	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,
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.7K bytes
    - Viewed (0)
  3. cmd/bucket-handlers.go

    		if forceDelete {
    			if rcfg, _ := globalBucketObjectLockSys.Get(bucket); rcfg.LockEnabled {
    				writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrMethodNotAllowed), r.URL)
    				return
    			}
    			rcfg, err := getReplicationConfig(ctx, bucket)
    			switch {
    			case err != nil:
    				if _, ok := err.(BucketReplicationConfigNotFound); !ok {
    					writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrMethodNotAllowed), r.URL)
    					return
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    			return objInfo, err
    		}
    		rcfg, err = globalBucketObjectLockSys.Get(bucket)
    		if err != nil {
    			return objInfo, err
    		}
    		replcfg, err = getReplicationConfig(ctx, bucket)
    		if err != nil {
    			return objInfo, err
    		}
    	}
    
    	// expiration attempted on a bucket with no lifecycle
    	// rules shall be rejected.
    	if lc == nil && opts.Expiration.Expire {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  5. cmd/object-handlers.go

    			rcfg, err := globalBucketObjectLockSys.Get(bucket)
    			if err != nil {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    				return
    			}
    			replcfg, err := getReplicationConfig(ctx, bucket)
    			if err != nil {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    				return
    			}
    			event := evalActionFromLifecycle(ctx, *lc, rcfg, replcfg, objInfo)
    			if event.Action.Delete() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  6. cmd/admin-handlers-users.go

    			}
    
    			lcfg, _ := globalBucketObjectLockSys.Get(bucket.Name)
    			quota, _ := globalBucketQuotaSys.Get(ctx, bucket.Name)
    			rcfg, _, _ := globalBucketMetadataSys.GetReplicationConfig(ctx, bucket.Name)
    			tcfg, _, _ := globalBucketMetadataSys.GetTaggingConfig(bucket.Name)
    
    			acctInfo.Buckets = append(acctInfo.Buckets, madmin.BucketAccessInfo{
    				Name:                    bucket.Name,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 90.6K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    			cache.Info.lifeCycle = lc
    		}
    	}
    
    	// Check if the current bucket has replication configuration
    	var rcfg *replication.Config
    	if rcfg, _, err = globalBucketMetadataSys.GetReplicationConfig(ctx, cache.Info.Name); err == nil {
    		if rcfg.HasActiveRules("", true) {
    			tgts, err := globalBucketTargetSys.ListBucketTargets(ctx, cache.Info.Name)
    			if err == nil {
    				cache.Info.replication = replicationConfig{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
Back to top