- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for tgtArns (0.13 sec)
-
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) -
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) -
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) -
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) -
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) -
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)