Package | Description |
---|---|
com.basho.riak.client.core |
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.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(String remoteAddress)
Sets the remote address 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(RiakNode.Builder builder,
List<String> remoteAddresses)
Build a set of RiakNodes.
|
Copyright © 2014. All rights reserved.