- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for TargetArn (0.23 sec)
-
internal/bucket/replication/destination.go
// used prior to multi-destination func (d Destination) LegacyArn() bool { return strings.HasPrefix(d.ARN, DestinationARNPrefix) } // TargetArn returns true if arn format has prefix "arn:minio:replication:::" // used for multi-destination targets func (d Destination) TargetArn() bool { return strings.HasPrefix(d.ARN, DestinationARNMinIOPrefix) } // MarshalXML - encodes to XML data.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4K bytes - Viewed (2) -
cmd/bucket-replication.go
var wg sync.WaitGroup var mu sync.Mutex for _, tgtEntry := range dsc.targetsMap { if !tgtEntry.Replicate { continue } // if dobj.TargetArn is not empty string, this is a case of specific target being re-synced. if dobj.TargetArn != "" && dobj.TargetArn != tgtEntry.Arn { continue } tgtClnt := globalBucketTargetSys.GetRemoteTargetClient(bucket, tgtEntry.Arn) if tgtClnt == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/metrics-v2.go
VariableLabels: map[string]string{"bucket": bucket, "targetArn": arn}, }) metrics = append(metrics, MetricV2{ Description: getRepFailedOperationsLastMinuteMD(bucketMetricNamespace), Value: stat.Failed.LastMinute.Count, VariableLabels: map[string]string{"bucket": bucket, "targetArn": arn}, }) metrics = append(metrics, MetricV2{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
internal/bucket/replication/replication.go
return nil } var rules []Rule for _, rule := range c.Rules { if rule.Status == Disabled { continue } if obj.TargetArn != "" && rule.Destination.ARN != obj.TargetArn && c.RoleArn != obj.TargetArn { continue } // Ignore other object level and prefix filters for resyncing target/listing bucket targets
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/object-api-datatypes.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
cmd/object-api-datatypes_gen.go
bts, err = z.ExistingObjResync.UnmarshalMsg(bts) if err != nil { err = msgp.WrapError(err, "ExistingObjResync") return } case "TargetArn": z.TargetArn, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "TargetArn") return } case "TargetStatuses": var zb0002 uint32 zb0002, bts, err = msgp.ReadMapHeaderBytes(bts) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 69.8K bytes - Viewed (0) -
cmd/site-replication.go
if targetsPtr, _ := globalBucketTargetSys.ListBucketTargets(ctx, bucket); targetsPtr != nil { targets = targetsPtr.Targets } targetARN := "" var updateTgt, updateBW bool var targetToUpdate madmin.BucketTarget for _, target := range targets { if target.Arn == ruleARN { targetARN = ruleARN updateBW = peer.DefaultBandwidth.Limit != 0 && target.BandwidthLimit == 0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/bucket-replication-handlers.go
return } tgtArns := config.FilterTargetArns( replication.ObjectOpts{ OpType: replication.ResyncReplicationType, TargetArn: arn, }) if len(tgtArns) == 0 { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrBadRequest, InvalidArgument{ Bucket: bucket,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 28 04:08:53 GMT 2023 - 23.2K bytes - Viewed (0)