module Cassandra

Creates a Cluster instance

Examples:

Connecting to localhost

cluster = Cassandra.cluster

Configuring Cluster

cluster = Cassandra.cluster(
            username: username,
            password: password,
            hosts: ['10.0.1.1', '10.0.1.2', '10.0.1.3']
          )

Parameters:

Name	Type	Details
options	Hash	(defaults to: {}) a customizable set of options

Keys for options:

Key	Type	Details
:hosts	Array<String, IPAddr>	default: ['127.0.0.1'] a list of initial addresses. Note that the entire list of cluster members will be discovered automatically once a connection to any hosts from the original list is successful.
:port	Integer	default: 9042 cassandra native protocol port.
:datacenter	String	default: nil name of current datacenter. First datacenter found will be assumed current by default. Note that you can skip this option if you specify only hosts from the local datacenter in :hosts option.
:connect_timeout	Numeric	default: 10 connection timeout in seconds. Setting value to nil will reset it to 5 seconds.
:timeout	Numeric	default: 10 request execution timeout in seconds. Setting value to nil will remove request timeout.
:heartbeat_interval	Numeric	default: 30 how often should a heartbeat be sent to determine if a connection is alive. Several things to note about this option. Only one heartbeat request will ever be outstanding on a given connection. Each heatbeat will be sent in at least :heartbeat_interval seconds after the last request has been sent on a given connection. Setting value to nil will remove connection timeout.
:idle_timeout	Numeric	default: 60 period of inactivity after which a connection is considered dead. Note that this value should be at least a few times larger than :heartbeat_interval. Setting value to nil will remove automatic connection termination.
:username	String	default: none username to use for authentication to cassandra. Note that you must also specify :password.
:password	String	default: none password to use for authentication to cassandra. Note that you must also specify :username.
:ssl	(Boolean or OpenSSL::SSL::SSLContext)	default: false enable default ssl authentication if true (not recommended). Also accepts an initialized OpenSSL::SSL::SSLContext. Note that this option should be ignored if :server_cert, :client_cert, :private_key or :passphrase are given.
:server_cert	String	default: none path to server certificate or certificate authority file.
:client_cert	String	default: none path to client certificate file. Note that this option is only required when encryption is configured to require client authentication.
:private_key	String	default: none path to client private key. Note that this option is only required when encryption is configured to require client authentication.
:passphrase	String	default: none passphrase for private key.
:compression	Symbol	default: none compression to use. Must be either :snappy or :lz4. Also note, that in order for compression to work, you must install ‘snappy’ or ‘lz4-ruby’ gems.
:load_balancing_policy	LoadBalancing::Policy	default: token aware data center aware round robin.
:address_resolution	Symbol	default: :none a pre-configured address resolver to use. Must be one of :none or :ec2_multi_region.
:reconnection_policy	Reconnection::Policy	default: Reconnection::Policies::Exponential. Note that the default policy is configured with (0.5, 30, 2).
:retry_policy	Retry::Policy	default: Retry::Policies::Default.
:logger	Logger	default: none logger. a Logger instance from the standard library or any object responding to standard log methods (#debug, #info, #warn, #error and #fatal).
:listeners	Enumerable<Listener>	default: none initial listeners. A list of initial cluster state listeners. Note that a :load_balancing policy is automatically registered with the cluster.
:consistency	Symbol	default: :one default consistency to use for all requests. Must be one of CONSISTENCIES.
:trace	Boolean	default: false whether or not to trace all requests by default.
:page_size	Integer	default: 10000 default page size for all select queries. Set this value to nil to disable paging.
:credentials	Hash{String => String}	default: none a hash of credentials - to be used with credentials authentication in cassandra 1.2. Note that if you specified :username and :password options, those credentials are configured automatically.
:auth_provider	Auth::Provider	default: none a custom auth provider to be used with SASL authentication in cassandra 2.0. Note that if you have specified :username and :password, then a Auth::Providers::Password will be used automatically.
:compressor	Compression::Compressor	default: none a custom compressor. Note that if you have specified :compression, an appropriate compressor will be provided automatically.
:address_resolution_policy	AddressResolution::Policy	default: AddressResolution::Policies::None a custom address resolution policy. Note that if you have specified :address_resolution, an appropriate address resolution policy will be provided automatically.
:futures_factory	Object<#all, #error, #value, #promise>	default: Future a futures factory to assist with integration into existing futures library. Note that promises returned by this object must conform to Promise api, which is not yet public. Things may change, use at your own risk.

Returns:

Type	Details
Cluster	a cluster instance

Creates a Cluster instance

Returns:

Type	Details
Future<Cluster>	a future resolving to the cluster instance.

See Also:

• cluster