Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for getReplicationConfig (0.12 sec)

  1. cmd/bucket-replication-handlers.go

    	if _, err := objectAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	config, _, err := globalBucketMetadataSys.GetReplicationConfig(ctx, bucket)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	configData, err := xml.Marshal(config)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  2. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  3. cmd/global-heal.go

    			}
    			// Check if bucket is object locked.
    			lr, err = globalBucketObjectLockSys.Get(bucket)
    			if err != nil {
    				retErr = err
    				healingLogIf(ctx, err)
    				continue
    			}
    			rcfg, err = getReplicationConfig(ctx, bucket)
    			if err != nil {
    				retErr = err
    				healingLogIf(ctx, err)
    				continue
    			}
    		}
    
    		if serverDebugLog {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  4. cmd/admin-bucket-handlers.go

    					return
    				}
    				rawDataFn(bytes.NewReader(configData), cfgPath, len(configData))
    			case bucketReplicationConfig:
    				config, _, err := globalBucketMetadataSys.GetReplicationConfig(ctx, bucket)
    				if err != nil {
    					if errors.Is(err, BucketReplicationConfigNotFound{Bucket: bucket}) {
    						continue
    					}
    					writeErrorResponse(ctx, w, exportError(ctx, err, cfgFile, bucket), r.URL)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  5. 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}) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  6. 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 {
    		set := set
    
    		filterLifecycle := func(bucket, object string, fi FileInfo) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  9. cmd/data-scanner.go

    		}
    
    		// Check if bucket is object locked.
    		lr, err = globalBucketObjectLockSys.Get(i.bucket)
    		if err != nil {
    			scannerLogOnceIf(ctx, err, i.bucket)
    			return
    		}
    
    		rcfg, err = getReplicationConfig(ctx, i.bucket)
    		if err != nil {
    			scannerLogOnceIf(ctx, err, i.bucket)
    			return
    		}
    	}
    
    	lcEvt := evalActionFromLifecycle(ctx, *i.lifeCycle, lr, rcfg, oi)
    	if i.debug {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top