Contents

module MixedGauge
  # Mapping of slot -> connection_name.
  class ClusterConfig
    attr_reader :name

    # @param [Symbol] name
    def initialize(name)
      @name = name
      @connection_registry = {}
    end

    # @param [Range] slots
    # @return [nil]
    def define_slots(slots)
      @slots = slots
      nil
    end

    # @param [Range] slots
    # @param [Symbol] connection connection name
    # @return [nil]
    def register(slots, connection)
      @connection_registry[slots] = connection
      nil
    end

    def validate_config!
      # TODO
    end

    # @return [Integer]
    def slot_count
      @slots.count
    end

    # @param [Integer] slot
    # @return [Symbol] registered connection name
    def fetch(slot)
      @connection_registry.find {|slot_range, name| slot_range.cover?(slot) }[1]
    end

    # @return [Array<Symbol>] An array of connection name
    def connections
      @connection_registry.values
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
mixed_gauge-0.1.4	lib/mixed_gauge/cluster_config.rb
mixed_gauge-0.1.3	lib/mixed_gauge/cluster_config.rb
mixed_gauge-0.1.2	lib/mixed_gauge/cluster_config.rb
mixed_gauge-0.1.1	lib/mixed_gauge/cluster_config.rb
mixed_gauge-0.1.0	lib/mixed_gauge/cluster_config.rb