Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for tgtArns (0.13 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 114.4K bytes
    - Viewed (0)
  3. pkg/apis/flowcontrol/validation/validation.go

    		}
    	} else {
    		for idx, tgtNS := range rule.Namespaces {
    			for _, msg := range apimachineryvalidation.ValidateNamespaceName(tgtNS, false) {
    				allErrs = append(allErrs, field.Invalid(fldPath.Child("namespaces").Index(idx), tgtNS, nsErrIntro+msg))
    			}
    		}
    	}
    
    	return allErrs
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 22:22:51 UTC 2023
    - 26.7K bytes
    - Viewed (0)
  4. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 01 01:09:56 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  5. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  6. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 184.3K bytes
    - Viewed (0)
Back to top