Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getRemoteTargetClient (1.08 sec)

  1. 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
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  2. 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 opts.CheckRemoteBucket { // validate remote bucket
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  3. 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)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
Back to top