Contents

module ActiveRecord
  module ShardFor
    # @abstract Subclass and override [#route] to inplement
    class ConnectionRouter
      attr_reader :cluster_config

      # @param [ActiveRecord::ShardFor::ClusterConfig]
      def initialize(cluster_config)
        @cluster_config = cluster_config
      end

      # Fetch shard by sharding key
      # @param [Object] key routing key
      def fetch_connection_name(key)
        cluster_config.fetch route(key)
      end

      # Decide routing for shard.
      # Override this method in subclass.
      # @param [Object] key sharding key
      def route(_key)
        raise NotImplementedError.new, 'Please impement this method'
      end

      private

      # @return [Integer] count of registered connection
      def connection_count
        cluster_config.connections.count
      end
    end
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
activerecord-shard_for-0.7.0	lib/activerecord/shard_for/connection_router.rb
activerecord-shard_for-0.6.1	lib/activerecord/shard_for/connection_router.rb
activerecord-shard_for-0.6.0	lib/activerecord/shard_for/connection_router.rb
activerecord-shard_for-0.5.0	lib/activerecord/shard_for/connection_router.rb
activerecord-shard_for-0.4.1	lib/activerecord/shard_for/connection_router.rb
activerecord-shard_for-0.4.0	lib/activerecord/shard_for/connection_router.rb
activerecord-shard_for-0.3.0	lib/activerecord/shard_for/connection_router.rb
activerecord-shard_for-0.2.1	lib/activerecord/shard_for/connection_router.rb
activerecord-shard_for-0.2.0	lib/activerecord/shard_for/connection_router.rb
activerecord-shard_for-0.1.2	lib/activerecord/shard_for/connection_router.rb
activerecord-shard_for-0.1.1	lib/activerecord/shard_for/connection_router.rb
activerecord-shard_for-0.1.0	lib/activerecord/shard_for/connection_router.rb