Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for tgtArns (0.21 sec)

  1. cmd/bucket-replication-handlers.go

    	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 {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrBadRequest, InvalidArgument{
    			Bucket: bucket,
    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-targets.go

    		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()
    					if ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  3. cmd/bucket-replication-utils.go

    	for _, v := range r.targets {
    		if v.Replicate {
    			return true
    		}
    	}
    	return false
    }
    
    func (r ResyncDecision) mustResyncTarget(tgtArn string) bool {
    	if r.targets == nil {
    		return false
    	}
    	v, ok := r.targets[tgtArn]
    	return ok && v.Replicate
    }
    
    // ResyncTargetDecision is struct that represents resync decision for this target
    type ResyncTargetDecision struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
Back to top