Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for FilterTargetArns (0.08 sec)

  1. internal/bucket/replication/replication.go

    				continue
    			}
    		}
    		return true
    	}
    	return false
    }
    
    // FilterTargetArns returns a slice of distinct target arns in the config
    func (c Config) FilterTargetArns(obj ObjectOpts) []string {
    	var arns []string
    
    	tgtsMap := make(map[string]struct{})
    	rules := c.FilterActionableRules(obj)
    	for _, rule := range rules {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 28 17:44:56 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    		ExistingObject: mopts.isExistingObjectReplication(),
    	}
    	tagStr, ok := mopts.meta[xhttp.AmzObjectTagging]
    	if ok {
    		opts.UserTags = tagStr
    	}
    	tgtArns := cfg.FilterTargetArns(opts)
    	for _, tgtArn := range tgtArns {
    		tgt := globalBucketTargetSys.GetRemoteTargetClient(bucket, tgtArn)
    		// the target online status should not be used here while deciding
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  3. cmd/bucket-targets.go

    		// 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}) {
    				if err == nil && (tgtArn == arnStr || rcfg.RoleArn == arnStr) {
    					sys.RLock()
    					_, ok := sys.arnRemotesMap[arnStr]
    					sys.RUnlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. cmd/bucket-replication-handlers.go

    		return
    	}
    
    	if !hasExistingObjEnabled {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrReplicationNoExistingObjects), r.URL)
    		return
    	}
    
    	tgtArns := config.FilterTargetArns(
    		replication.ObjectOpts{
    			OpType:    replication.ResyncReplicationType,
    			TargetArn: arn,
    		})
    
    	if len(tgtArns) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
Back to top