com.basho.riak.client.core

Class RiakCluster.Builder

java.lang.Object

com.basho.riak.client.core.RiakCluster.Builder

Enclosing class:

RiakCluster

public static class RiakCluster.Builder
extends Object

Builder used to create RiakCluster instances.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_EXECUTION_ATTEMPTS

Constructor Summary

Constructors

Constructor and Description
RiakCluster.Builder(List<RiakNode> riakNodes) Instantiate a Builder containing the supplied RiakNodes
RiakCluster.Builder(RiakNode node) Instantiate a Builder containing a single RiakNode

Method Summary

Methods

Modifier and Type	Method and Description
RiakCluster	build() Instantiates the RiakCluster
RiakCluster.Builder	withBootstrap(io.netty.bootstrap.Bootstrap bootstrap) The Netty Bootstrap this cluster will use.
RiakCluster.Builder	withExecutionAttempts(int numberOfAttempts) Sets the number of times the RiakCluster will attempt an operation before returning it as failed.
RiakCluster.Builder	withExecutor(ScheduledExecutorService executor) Sets the Threadpool for this cluster.
RiakCluster.Builder	withNodeManager(NodeManager nodeManager) Sets the NodeManager for this RiakCluster If none is provided the DefaultNodeManager will be used

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_EXECUTION_ATTEMPTS

public static final int DEFAULT_EXECUTION_ATTEMPTS

See Also:

Constant Field Values

Constructor Detail

RiakCluster.Builder

public RiakCluster.Builder(List<RiakNode> riakNodes)

Instantiate a Builder containing the supplied RiakNodes

Parameters:

riakNodes - - a List of unstarted RiakNode objects

RiakCluster.Builder

public RiakCluster.Builder(RiakNode node)

Instantiate a Builder containing a single RiakNode

Parameters:

node -

Method Detail

withExecutionAttempts

public RiakCluster.Builder withExecutionAttempts(int numberOfAttempts)

Sets the number of times the RiakCluster will attempt an operation before returning it as failed.

Parameters:

numberOfAttempts -

Returns:

this

withNodeManager

public RiakCluster.Builder withNodeManager(NodeManager nodeManager)

Sets the NodeManager for this RiakCluster If none is provided the DefaultNodeManager will be used

Parameters:

nodeManager -

Returns:

this

withExecutor

public RiakCluster.Builder withExecutor(ScheduledExecutorService executor)

Sets the Threadpool for this cluster. This threadpool is passed down to the RiakNodes. At the very least it needs to have two threads available. It is not necessary to supply your own as the RiakCluster will instantiate one upon construction if this is not asSet.

Parameters:

executor -

Returns:

this

withBootstrap

public RiakCluster.Builder withBootstrap(io.netty.bootstrap.Bootstrap bootstrap)

The Netty Bootstrap this cluster will use. This Bootstrap is passed down to the RiakNodes. It is not necessary to supply your own as the RiakCluster will instantiate one upon construction if this is not asSet.

Parameters:

bootstrap -

Returns:

this

build

public RiakCluster build()
                  throws UnknownHostException

Instantiates the RiakCluster

Returns:

a new RiakCluster

Throws:

UnknownHostException - if a node fails to start due to a DNS lookup