Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GetRemoteTargetClient (0.22 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
    	}
    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)
  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 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)
  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)
    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)
Back to top