Contents

module MixedGauge
  # Support parallel execution with each shard and deal with AR connection
  # management in parallel execution.
  class AllShardsInParallel
    # @param [Array<Class>] shards An array of shard model class
    # @param [Expeditor::Service] service
    def initialize(shards, service:)
      @shards = shards
      @service = service
    end

    # @yield [Class] A shard model class
    # @return [Array] A result
    # @example
    #   User.all_shards_in_parallel.map(&:count).reduce(&:+)
    def map(&block)
      commands = @shards.map do |m|
        Expeditor::Command.new(service: @service) { m.connection_pool.with_connection { yield m } }
      end
      commands.each(&:start)
      commands.map(&:get)
    end

    # @yield [Class] A shard model class
    # @return [Array] A result
    # @example
    #   User.all_shards_in_parallel.flat_map {|m| m.where(age: 1) }
    def flat_map(&block)
      map(&block).flatten
    end

    # @yield [Class] A shard model class
    # @return [MixedGauge::AllShardsInParallel]
    # @example
    #   User.all_shards_in_parallel.each {|m| puts m.count }
    def each(&block)
      map(&block) if block_given?
      self
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
mixed_gauge-1.2.0.beta2	lib/mixed_gauge/all_shards_in_parallel.rb
mixed_gauge-1.2.0.beta1	lib/mixed_gauge/all_shards_in_parallel.rb