module CassandraConnection

Public Instance Methods

get_session(host, port, keyspace, connect_timeout, username, password) click to toggle source

# 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