Package | Description |
---|---|
com.basho.riak.client.api |
Contains the main RiakClient used to query Riak.
|
com.basho.riak.client.core |
Modifier and Type | Method and Description |
---|---|
static RiakNode.Builder |
RiakClient.createDefaultNodeBuilder() |
Modifier and Type | Method and Description |
---|---|
static RiakClient |
RiakClient.newClient(Collection<HostAndPort> hosts,
RiakNode.Builder nodeBuilder)
Static factory method to create a new client instance.
|
static RiakClient |
RiakClient.newClient(RiakNode.Builder nodeBuilder,
List<String> addresses)
Static factory method to create a new client instance.
|
static RiakClient |
RiakClient.newClient(RiakNode.Builder nodeBuilder,
String... addresses)
Static factory method to create a new client instance.
|
Modifier and Type | Method and Description |
---|---|
RiakNode.Builder |
RiakNode.Builder.withAuth(String username,
String password,
KeyStore trustStore)
Set the credentials for Riak security and authentication.
|
RiakNode.Builder |
RiakNode.Builder.withAuth(String username,
String password,
KeyStore trustStore,
KeyStore keyStore,
String keyPassword)
Set the credentials for Riak security and authentication.
|
RiakNode.Builder |
RiakNode.Builder.withBlockOnMaxConnections(boolean block)
Set whether to block if all connections are in use.
|
RiakNode.Builder |
RiakNode.Builder.withBootstrap(io.netty.bootstrap.Bootstrap bootstrap)
Provides a Netty Bootstrap for this node to use.
|
RiakNode.Builder |
RiakNode.Builder.withConnectionTimeout(int connectionTimeoutInMillis)
Set the connection timeout used when making new connections
|
RiakNode.Builder |
RiakNode.Builder.withExecutor(ScheduledExecutorService executor)
Provides an executor for this node to use for internal maintenance tasks.
|
RiakNode.Builder |
RiakNode.Builder.withHealthCheck(HealthCheckFactory factory)
Set the HealthCheckFactory used to determine if this RiakNode is healthy.
|
RiakNode.Builder |
RiakNode.Builder.withIdleTimeout(int idleTimeoutInMillis)
Set the idle timeout used to reap inactive connections.
|
RiakNode.Builder |
RiakNode.Builder.withMaxConnections(int maxConnections)
Set the maximum number of connections allowed.
|
RiakNode.Builder |
RiakNode.Builder.withMinConnections(int minConnections)
Set the minimum number of active connections to maintain.
|
RiakNode.Builder |
RiakNode.Builder.withRemoteAddress(HostAndPort hp)
Specifies the remote host and remote port for this RiakNode.
|
RiakNode.Builder |
RiakNode.Builder.withRemoteAddress(String remoteAddress)
Sets the remote address for this RiakNode.
|
RiakNode.Builder |
RiakNode.Builder.withRemoteHost(HostAndPort hostAndPOrt)
Sets the remote host and port for this RiakNode.
|
RiakNode.Builder |
RiakNode.Builder.withRemotePort(int port)
Specifies the remote port for this RiakNode.
|
Modifier and Type | Method and Description |
---|---|
static List<RiakNode> |
RiakNode.Builder.buildNodes(Collection<HostAndPort> remoteHosts,
RiakNode.Builder builder)
Build a set of RiakNodes.
|
static List<RiakNode> |
RiakNode.Builder.buildNodes(RiakNode.Builder builder,
List<String> remoteAddresses)
Build a set of RiakNodes.
|
static List<RiakNode> |
RiakNode.Builder.buildNodes(RiakNode.Builder builder,
String... remoteAddresses)
Build a set of RiakNodes.
|
Constructor and Description |
---|
Builder(Collection<HostAndPort> remoteHosts,
RiakNode.Builder nodeBuilder)
Instantiate a Builder containing the
RiakNode s that will be build by using provided builder. |
Builder(RiakNode.Builder nodeBuilder,
List<String> remoteAddresses)
Instantiate a Builder containing the
RiakNode s that will be build by using provided builder. |
Builder(RiakNode.Builder nodeBuilder,
String... remoteAddresses)
Instantiate a Builder containing the
RiakNode s that will be build by using provided builder. |
Copyright © 2016. All rights reserved.