Contents

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

    module ClassMethods
      DEFAULT_OPTIONS = {
        servers: "127.0.0.1:9160",
        thrift: {}
      }
      def establish_connection(spec)
        spec.reverse_merge!(DEFAULT_OPTIONS)
        self.connection = Cassandra.new(spec[:keyspace], spec[:servers], spec[:thrift].symbolize_keys!)
      end
    end
  end
end

Version data entries

116 entries across 116 versions & 2 rubygems

Version	Path
sessionm-cassandra_object-2.2.38	lib/cassandra_object/connection.rb
sessionm-cassandra_object-2.2.37	lib/cassandra_object/connection.rb
sessionm-cassandra_object-2.2.36	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.10.11	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.10.10	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.10.9	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.10.8	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.10.7	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.10.6	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.10.5	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.10.4	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.10.3	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.10.2	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.10.1	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.10.0	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.9.2	lib/cassandra_object/connection.rb
sessionm-cassandra_object-2.2.35	lib/cassandra_object/connection.rb
sessionm-cassandra_object-2.2.34	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.9.1	lib/cassandra_object/connection.rb
gotime-cassandra_object-2.9.0	lib/cassandra_object/connection.rb