Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 9 of 9 for getReplicationConfig (0.13 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. cmd/bucket-replication.go

    	ReplicationSsecChecksumHeader = "X-Minio-Replication-Ssec-Crc"
    )
    
    // gets replication config associated to a given bucket name.
    func getReplicationConfig(ctx context.Context, bucketName string) (rc *replication.Config, err error) {
    	rCfg, _, err := globalBucketMetadataSys.GetReplicationConfig(ctx, bucketName)
    	if err != nil && !errors.Is(err, BucketReplicationConfigNotFound{Bucket: bucketName}) {
    		return rCfg, err
    	}
    	return rCfg, nil
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  7. 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() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 120.6K bytes
    - Click Count (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,
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 30.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