Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for tgtArns (0.11 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-replication.go

    		VersionID:    dobj.VersionID,
    		OpType:       replication.DeleteReplicationType,
    	}
    	tgtArns := rcfg.FilterTargetArns(opts)
    	dsc.targetsMap = make(map[string]replicateTargetDecision, len(tgtArns))
    	if len(tgtArns) == 0 {
    		return dsc
    	}
    	var sync, replicate bool
    	for _, tgtArn := range tgtArns {
    		opts.TargetArn = tgtArn
    		replicate = rcfg.Replicate(opts)
    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

    		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)
  4. 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)
  5. cmd/site-replication.go

    				Bucket:    bucket,
    				Status:    ResyncFailed.String(),
    			})
    			continue
    		}
    		// mark remote target for this deployment with the new reset id
    		tgtArn := globalBucketTargetSys.getRemoteARNForPeer(bucket, peer)
    		if tgtArn == "" {
    			res.Buckets = append(res.Buckets, madmin.ResyncBucketStatus{
    				ErrDetail: fmt.Sprintf("no valid remote target found for this peer %s (%s)", peer.Name, peer.DeploymentID),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
Back to top