org.stuartgunter.dropwizard.cassandra

Class CassandraFactory

java.lang.Object

org.stuartgunter.dropwizard.cassandra.CassandraFactory

public class CassandraFactory
extends Object

A factory for configuring the Cassandra bundle.

Configuration Parameters:

Name	Default	Description
clusterName	Defaults to the cluster name provided by the Cassandra driver.	The name of the cluster, as defined by the Cassandra driver; also used in metrics and health checks.
keyspace	No default. If provided, this will be included in the health check.	The name of the keyspace to connect to (used in health checks).
contactPoints	No default. You must provide a list of contact points for the Cassandra driver.
port	9042	The port to use to connect to the Cassandra host.
protocolVersion	-1	The native protocol version to use.
compression	NONE	Sets the compression to use for the transport. Must a value in the compression enum.
reconnectionPolicy	No default.	The reconnection policy to use.
authProvider	No default.	The auth provider to use.
retryPolicy	No default.	The retry policy to use.
queryOptions	No default.	The QueryOptions to use.
socketOptions	No default.	The SocketOptions to use
poolingOptions	No default.	The pooling options to use.
metricsEnabled	true	Whether or not to enable metrics reporting.
jmxEnabled	false	Whether or not to enable JMX metrics reporting. This should ideally remain disabled in a Dropwizard app, as metrics reporters should be configured via the metrics configuration option.
shutdownGracePeriod	30 seconds	The time to wait while the cluster closes gracefully; after which, the cluster will be forcefully terminated.

Constructor Summary

Constructors

Constructor and Description
CassandraFactory()

Method Summary

Modifier and Type	Method and Description
com.datastax.driver.core.Cluster	build(io.dropwizard.setup.Environment environment)
AuthProviderFactory	getAuthProvider()
String	getClusterName()
com.datastax.driver.core.ProtocolOptions.Compression	getCompression()
String[]	getContactPoints()
String	getKeyspace()
PoolingOptionsFactory	getPoolingOptions()
int	getPort()
int	getProtocolVersion()
com.datastax.driver.core.QueryOptions	getQueryOptions()
ReconnectionPolicyFactory	getReconnectionPolicy()
RetryPolicyFactory	getRetryPolicy()
io.dropwizard.util.Duration	getShutdownGracePeriod()
com.datastax.driver.core.SocketOptions	getSocketOptions()
boolean	isJmxEnabled()
boolean	isMetricsEnabled()
void	setAuthProvider(AuthProviderFactory authProvider)
void	setClusterName(String clusterName)
void	setCompression(com.datastax.driver.core.ProtocolOptions.Compression compression)
void	setContactPoints(String[] contactPoints)
void	setJmxEnabled(boolean jmxEnabled)
void	setKeyspace(String keyspace)
void	setMetricsEnabled(boolean metricsEnabled)
void	setPoolingOptions(PoolingOptionsFactory poolingOptions)
void	setPort(int port)
void	setProtocolVersion(int protocolVersion)
void	setQueryOptions(com.datastax.driver.core.QueryOptions queryOptions)
void	setReconnectionPolicy(ReconnectionPolicyFactory reconnectionPolicy)
void	setRetryPolicy(RetryPolicyFactory retryPolicy)
void	setShutdownGracePeriod(io.dropwizard.util.Duration shutdownGracePeriod)
void	setSocketOptions(com.datastax.driver.core.SocketOptions socketOptions)

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraFactory

public CassandraFactory()

Method Detail

getClusterName

public String getClusterName()

setClusterName

public void setClusterName(String clusterName)

getKeyspace

public String getKeyspace()

setKeyspace

public void setKeyspace(String keyspace)

getContactPoints

public String[] getContactPoints()

setContactPoints

public void setContactPoints(String[] contactPoints)

getPort

public int getPort()

setPort

public void setPort(int port)

getProtocolVersion

public int getProtocolVersion()

setProtocolVersion

public void setProtocolVersion(int protocolVersion)

getCompression

public com.datastax.driver.core.ProtocolOptions.Compression getCompression()

setCompression

public void setCompression(com.datastax.driver.core.ProtocolOptions.Compression compression)

getReconnectionPolicy

public ReconnectionPolicyFactory getReconnectionPolicy()

setReconnectionPolicy

public void setReconnectionPolicy(ReconnectionPolicyFactory reconnectionPolicy)

getAuthProvider

public AuthProviderFactory getAuthProvider()

setAuthProvider

public void setAuthProvider(AuthProviderFactory authProvider)

getRetryPolicy

public RetryPolicyFactory getRetryPolicy()

setRetryPolicy

public void setRetryPolicy(RetryPolicyFactory retryPolicy)

getQueryOptions

public com.datastax.driver.core.QueryOptions getQueryOptions()

setQueryOptions

public void setQueryOptions(com.datastax.driver.core.QueryOptions queryOptions)

getSocketOptions

public com.datastax.driver.core.SocketOptions getSocketOptions()

setSocketOptions

public void setSocketOptions(com.datastax.driver.core.SocketOptions socketOptions)

getPoolingOptions

public PoolingOptionsFactory getPoolingOptions()

setPoolingOptions

public void setPoolingOptions(PoolingOptionsFactory poolingOptions)

isMetricsEnabled

public boolean isMetricsEnabled()

setMetricsEnabled

public void setMetricsEnabled(boolean metricsEnabled)

isJmxEnabled

public boolean isJmxEnabled()

setJmxEnabled

public void setJmxEnabled(boolean jmxEnabled)

getShutdownGracePeriod

public io.dropwizard.util.Duration getShutdownGracePeriod()

setShutdownGracePeriod

public void setShutdownGracePeriod(io.dropwizard.util.Duration shutdownGracePeriod)

build

public com.datastax.driver.core.Cluster build(io.dropwizard.setup.Environment environment)