public class

RiakProtobufClientConfigurationAdapter

extends Object
implements RiakClientConfigurationAdapter<T extends Configuration>
java.lang.Object
   ↳ org.mule.modules.riak.config.RiakProtobufClientConfigurationAdapter

Class Overview

An adapter that allows DevKit to generate a configuration for Riak's PBClientConfig.

Summary

Fields
private PBClientConfig.Builder builder
private long connectionWaitTimeoutMillis How many milliseconds to block trying to obtain a connection from the pool before failing.
private String host The host address for the Riak protocol buffers interface.
private long idleConnectionTTLMillis How many milliseconds an idle connection survives in the pool before it is closed.
private int initialPoolSize The initial size for the connection pool.
private int poolSize The hard limit for the connection pool.
private int port The port for the Riak protocol buffers interface.
private int requestTimeoutMillis How many milliseconds to block/wait trying to read/write from/to a connection (This is the SO_TIMEOUT parameter on the Socket).
private int socketBufferSizeKb The size for the protocol buffer socket's read, write and socket buffers (in kilobytes).
Public Constructors
RiakProtobufClientConfigurationAdapter()
Public Methods
PBClientConfig buildRiakConfiguration()
long getConnectionWaitTimeoutMillis()
String getHost()
long getIdleConnectionTTLMillis()
int getInitialPoolSize()
int getPoolSize()
int getPort()
int getRequestTimeoutMillis()
int getSocketBufferSizeKb()
void setConnectionWaitTimeoutMillis(long connectionWaitTimeoutMillis)
void setHost(String host)
void setIdleConnectionTTLMillis(long idleConnectionTTLMillis)
void setInitialPoolSize(int initialPoolSize)
void setPoolSize(int poolSize)
void setPort(int port)
void setRequestTimeoutMillis(int requestTimeoutMillis)
void setSocketBufferSizeKb(int socketBufferSizeKb)
[Expand]
Inherited Methods
From class java.lang.Object
From interface org.mule.modules.riak.config.RiakClientConfigurationAdapter

Fields

private PBClientConfig.Builder builder

private long connectionWaitTimeoutMillis

How many milliseconds to block trying to obtain a connection from the pool before failing.

private String host

The host address for the Riak protocol buffers interface.

private long idleConnectionTTLMillis

How many milliseconds an idle connection survives in the pool before it is closed.

private int initialPoolSize

The initial size for the connection pool. The connection pool will create this many connections when the pool starts up.

private int poolSize

The hard limit for the connection pool.

private int port

The port for the Riak protocol buffers interface.

private int requestTimeoutMillis

How many milliseconds to block/wait trying to read/write from/to a connection (This is the SO_TIMEOUT parameter on the Socket).

private int socketBufferSizeKb

The size for the protocol buffer socket's read, write and socket buffers (in kilobytes). Total buffers per connection will be 3 times this value.

Public Constructors

public RiakProtobufClientConfigurationAdapter ()

Public Methods

public PBClientConfig buildRiakConfiguration ()

public long getConnectionWaitTimeoutMillis ()

public String getHost ()

public long getIdleConnectionTTLMillis ()

public int getInitialPoolSize ()

public int getPoolSize ()

public int getPort ()

public int getRequestTimeoutMillis ()

public int getSocketBufferSizeKb ()

public void setConnectionWaitTimeoutMillis (long connectionWaitTimeoutMillis)

Parameters
connectionWaitTimeoutMillis

public void setHost (String host)

Parameters
host

public void setIdleConnectionTTLMillis (long idleConnectionTTLMillis)

Parameters
idleConnectionTTLMillis

public void setInitialPoolSize (int initialPoolSize)

Parameters
initialPoolSize

public void setPoolSize (int poolSize)

Parameters
poolSize

public void setPort (int port)

Parameters
port

public void setRequestTimeoutMillis (int requestTimeoutMillis)

Parameters
requestTimeoutMillis

public void setSocketBufferSizeKb (int socketBufferSizeKb)

Parameters
socketBufferSizeKb