com.basho.riak.client.raw.http
Class HTTPClusterClient

java.lang.Object
  com.basho.riak.client.raw.ClusterClient<HTTPClientConfig>
      com.basho.riak.client.raw.http.HTTPClusterClient

All Implemented Interfaces:

RawClient

public class HTTPClusterClient
extends ClusterClient<HTTPClientConfig>

Cluster client that creates a collection of HTTPClientAdapter RawClient instances from a given HTTPClusterConfig

NOTE: In the case the the HTTPClusterConfig#getMaxConnections is NOT ClusterConfig.UNLIMITED_CONNECTIONS an HttpClient delegate is created for each node. This is to ensure that the cluster maximum connections limit is enforced. The HTTPClientConfig.getHttpClient() value for each node config is, therefore, ignored.

Author:

russell

Constructor Summary

HTTPClusterClient(ClusterConfig<HTTPClientConfig> clusterConfig)

Method Summary

protected RawClient[]	fromConfig(ClusterConfig<HTTPClientConfig> clusterConfig) Create an array of clients for the cluster from the given ClusterConfig.
Transport	getTransport() The raw transport name.

Methods inherited from class com.basho.riak.client.raw.ClusterClient

delete, delete, delete, fetch, fetch, fetch, fetchBucket, fetchIndex, generateAndSetClientId, getClientId, head, linkWalk, listBuckets, listKeys, mapReduce, ping, setClientId, shutdown, stats, store, store, updateBucket

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HTTPClusterClient

public HTTPClusterClient(ClusterConfig<HTTPClientConfig> clusterConfig)
                  throws IOException

Parameters:

clusterConfig -

Throws:

IOException

Method Detail

fromConfig

protected RawClient[] fromConfig(ClusterConfig<HTTPClientConfig> clusterConfig)
                          throws IOException

Description copied from class: ClusterClient

Create an array of clients for the cluster from the given ClusterConfig.

Specified by:

fromConfig in class ClusterClient<HTTPClientConfig>

Returns:

the array of RawClient delegates that make up the cluster

Throws:

IOException

getTransport

public Transport getTransport()

Description copied from interface: RawClient

The raw transport name.

Returns:

the Transport for the client or null if not implemented.