Contents

module CassandraObject
  module Connection
    extend ActiveSupport::Concern
    
    included do
      class_attribute :connection
    end

    module ClassMethods
      DEFAULT_OPTIONS = {
        servers: "127.0.0.1:9160",
      }
      DEFAULT_THRIFT_OPTIONS = {
        exception_class_overrides: [],
      }

      # This doesn't open a connection. It merely conifgures the connection object.
      def establish_connection(config)
        spec = config.reverse_merge(DEFAULT_OPTIONS)

        spec[:thrift] = (spec[:thrift] || {}).reverse_merge(DEFAULT_THRIFT_OPTIONS)
        spec[:thrift][:exception_class_overrides] = spec[:thrift][:exception_class_overrides].map(&:constantize)

        self.connection = Cassandra.new(spec[:keyspace], spec[:servers], spec[:thrift])
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
sessionm-cassandra_object-2.3.5	lib/cassandra_object/connection.rb
sessionm-cassandra_object-2.3.4	lib/cassandra_object/connection.rb
sessionm-cassandra_object-2.3.3	lib/cassandra_object/connection.rb
sessionm-cassandra_object-2.3.2	lib/cassandra_object/connection.rb
sessionm-cassandra_object-2.3.1	lib/cassandra_object/connection.rb
sessionm-cassandra_object-2.3.0	lib/cassandra_object/connection.rb