- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for GetRemoteTargetClient (0.22 sec)
-
cmd/bucket-targets.go
sys.arnErrsMap[arn] = arnErrs{ updateInProgress: v.updateInProgress, count: v.count + 1, } } } // GetRemoteTargetClient returns minio-go client for replication target instance func (sys *BucketTargetSys) GetRemoteTargetClient(bucket, arn string) *TargetClient { sys.RLock() tgt := sys.arnRemotesMap[arn] sys.RUnlock() if tgt.Client != nil { return tgt.Client }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/bucket-replication.go
} if arn.Type != madmin.ReplicationService { return sameTarget, toAPIError(ctx, BucketRemoteArnTypeInvalid{Bucket: bucket}) } clnt := globalBucketTargetSys.GetRemoteTargetClient(bucket, arnStr) if clnt == nil { return sameTarget, toAPIError(ctx, BucketRemoteTargetNotFound{Bucket: bucket}) } if checkRemote { // validate remote bucket
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/bucket-replication-handlers.go
return } buf := bytes.Repeat([]byte("a"), 8) for _, rule := range replicationConfig.Rules { if rule.Status == replication.Disabled { continue } clnt := globalBucketTargetSys.GetRemoteTargetClient(bucket, rule.Destination.Bucket) if clnt == nil { writeErrorResponse(ctx, w, errorCodes.ToAPIErrWithErr(ErrRemoteTargetNotFoundError, fmt.Errorf("replication config with rule ID %s has a stale target", rule.ID)), r.URL)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Oct 28 04:08:53 GMT 2023 - 23.2K bytes - Viewed (0)