Module: CassandraConnection

Included in:
Fluent::CassandraInsertor, Fluent::CassandraSelector, Fluent::CassandraUpdatetor, Fluent::CassandraUpsertor
Defined in:
lib/fluent/plugin/utils/cassandra_connection.rb

Instance Method Summary collapse

Instance Method Details

#get_session(host, port, keyspace, connect_timeout, username, password) ⇒ Object 



5
6
7
8
9
10
11
12
13
 
# File 'lib/fluent/plugin/utils/cassandra_connection.rb', line 5

def get_session(host, port, keyspace, connect_timeout, username, password)
  hostNode = host.split(",")
  if self.username
    cluster = ::Cassandra.cluster(hosts: hostNode, port: port, connect_timeout: connect_timeout, username: username, password: password)
  else
    cluster = ::Cassandra.cluster(hosts: hostNode, port: port, connect_timeout: connect_timeout)
  end
  cluster.connect(keyspace)
end