Contents

module CassandraObject
  module AsyncConnection
    extend ActiveSupport::Concern
    
    included do
      class_attribute :connection_spec

      class_eval do
        @@fiber_connections = {}
        def self.connection()
          @@fiber_connections[Fiber.current.object_id] ||=
            begin
              spec = connection_spec.dup
              
              if EM.reactor_running?
                require 'thrift_client/event_machine'
                spec[:thrift].merge!(:transport => Thrift::EventMachineTransport,
                                     :transport_wrapper => nil)
              end
              
              Cassandra.new(spec[:keyspace], spec[:servers], spec[:thrift])
            end
        end
        def self.connection?() !!connection end

        def connection
          defined?(@connection) ? @connection : singleton_class.connection
        end

        def connection?
          !!connection
        end
      end
    end

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

Version data entries

21 entries across 21 versions & 1 rubygems

Version	Path
sessionm-cassandra_object-2.2.42	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.41	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.40	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.39	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.38	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.37	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.36	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.35	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.34	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.33	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.32	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.31	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.30	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.29	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.28	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.27	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.26	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.24	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.20	lib/cassandra_object/async_connection.rb
sessionm-cassandra_object-2.2.18	lib/cassandra_object/async_connection.rb