Contents

require 'octopus/load_balancing'

# The round-robin load balancing of slaves belonging to the same shard.
# It is a pool that contains slaves which queries are distributed to.
module Octopus
  module LoadBalancing
    class RoundRobin
      def initialize(slaves_list)
        raise Octopus::Exception.new("No slaves available") if slaves_list.empty?
        @slaves_list = slaves_list
        @slave_index = 0
      end

      # Returns the next available slave in the pool
      def next(options)
        @slaves_list[@slave_index = (@slave_index + 1) % @slaves_list.length]
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 3 rubygems

Version	Path
ar-octopus-ruby-3-0.11.3	lib/octopus/load_balancing/round_robin.rb
ar-octopus-ruby-3-0.11.2	lib/octopus/load_balancing/round_robin.rb
ar-octopus-0.10.2	lib/octopus/load_balancing/round_robin.rb
ar-octopus-0.10.1	lib/octopus/load_balancing/round_robin.rb
ar-octopus-0.10.0	lib/octopus/load_balancing/round_robin.rb
ar-octopus-master-0.9.2.1	lib/octopus/load_balancing/round_robin.rb
ar-octopus-0.9.2	lib/octopus/load_balancing/round_robin.rb
ar-octopus-0.9.1	lib/octopus/load_balancing/round_robin.rb