Package | Description |
---|---|
com.basho.riak.client.core |
Modifier and Type | Method and Description |
---|---|
RiakNode |
RiakNode.Builder.build()
Builds a RiakNode.
|
RiakNode |
RiakNode.setBootstrap(io.netty.bootstrap.Bootstrap bootstrap)
Sets the Netty
Bootstrap for this Node's connections. |
RiakNode |
RiakNode.setConnectionTimeout(int connectionTimeoutInMillis)
Sets the connection timeout for new connections.
|
RiakNode |
RiakNode.setExecutor(ScheduledExecutorService executor)
Sets the
ScheduledExecutorService for this Node and its pool(s). |
RiakNode |
RiakNode.setIdleTimeout(int idleTimeoutInMillis)
Sets the connection idle timeout for connections.
|
RiakNode |
RiakNode.setMaxConnections(int maxConnections)
Sets the maximum number of connections allowed.
|
RiakNode |
RiakNode.setMinConnections(int minConnections)
Sets the minimum number of active connections to be maintained.
|
RiakNode |
RiakNode.start() |
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.
|
List<RiakNode> |
RiakCluster.getNodes()
Returns a copy of the list of nodes in this cluster.
|
Modifier and Type | Method and Description |
---|---|
void |
RiakCluster.addNode(RiakNode node)
Adds a
RiakNode to this cluster. |
void |
NodeManager.addNode(RiakNode newNode) |
void |
DefaultNodeManager.addNode(RiakNode newNode) |
static RiakCluster.Builder |
RiakCluster.builder(RiakNode node) |
boolean |
NodeManager.executeOnNode(FutureOperation operation,
RiakNode previousNode) |
boolean |
DefaultNodeManager.executeOnNode(FutureOperation operation,
RiakNode previousNode) |
void |
RiakCluster.nodeStateChanged(RiakNode node,
RiakNode.State state) |
void |
NodeStateListener.nodeStateChanged(RiakNode node,
RiakNode.State state) |
void |
DefaultNodeManager.nodeStateChanged(RiakNode node,
RiakNode.State state) |
boolean |
RiakCluster.removeNode(RiakNode node)
Removes the provided node from the cluster.
|
boolean |
NodeManager.removeNode(RiakNode node) |
boolean |
DefaultNodeManager.removeNode(RiakNode node) |
Modifier and Type | Method and Description |
---|---|
static RiakCluster.Builder |
RiakCluster.builder(List<RiakNode> nodes) |
void |
NodeManager.init(List<RiakNode> nodes) |
void |
DefaultNodeManager.init(List<RiakNode> nodes) |
Constructor and Description |
---|
Builder(RiakNode node)
Instantiate a Builder containing a single
RiakNode |
Constructor and Description |
---|
Builder(List<RiakNode> riakNodes)
Instantiate a Builder containing the supplied
RiakNode s |
Copyright © 2016. All rights reserved.