Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 9 of 9 for GetReplicationConfig (0.23 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/bucket-metadata-sys.go

    		}
    		return nil, time.Time{}, err
    	}
    	return meta.quotaConfig, meta.QuotaConfigUpdatedAt, nil
    }
    
    // GetReplicationConfig returns configured bucket replication config
    // The returned object may not be modified.
    func (sys *BucketMetadataSys) GetReplicationConfig(ctx context.Context, bucket string) (*replication.Config, time.Time, error) {
    	meta, reloaded, err := sys.GetConfig(ctx, bucket)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  2. docs/bucket/replication/README.md

    Daryl White <******@****.***> 1755022836 -0400
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 18.3K bytes
    - Click Count (0)
  3. cmd/bucket-targets.go

    	if err != nil {
    		return BucketRemoteArnInvalid{Bucket: bucket}
    	}
    
    	if arn.Type == madmin.ReplicationService {
    		// reject removal of remote target if replication configuration is present
    		rcfg, err := getReplicationConfig(ctx, bucket)
    		if err == nil && rcfg != nil {
    			for _, tgtArn := range rcfg.FilterTargetArns(replication.ObjectOpts{OpType: replication.AllReplicationType}) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.9K bytes
    - Click Count (0)
  4. cmd/erasure-server-pool-decom.go

    			return err
    		}
    
    		// Check if bucket is object locked.
    		lr, err = globalBucketObjectLockSys.Get(bi.Name)
    		if err != nil {
    			return err
    		}
    
    		rcfg, err = getReplicationConfig(ctx, bi.Name)
    		if err != nil {
    			return err
    		}
    	}
    
    	for setIdx, set := range pool.sets {
    		filterLifecycle := func(bucket, object string, fi FileInfo) bool {
    			if lc == nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  5. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  6. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  7. cmd/site-replication.go

    		// not a problem as we are always using the same replication
    		// rule ID - if the rule already exists, it is just replaced.
    		replicationConfigS, _, err := globalBucketMetadataSys.GetReplicationConfig(ctx, bucket)
    		if err != nil {
    			_, ok := err.(BucketReplicationConfigNotFound)
    			if !ok {
    				return err
    			}
    		}
    		var replicationConfig replication.Config
    		if replicationConfigS != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  8. 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{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  9. 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,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 90.6K bytes
    - Click Count (0)
Back to Top