mbj/esearch

# encoding: UTF-8

module Esearch
  # Handle for an elasticsearch cluster
  class Cluster
    PATH = Pathname.new('/').freeze

    include Adamantium::Flat, Concord.new(:connection)

    # Return connection
    #
    # @return [Connection]
    #
    # @api private
    #
    attr_reader :connection

    # Return handler for index
    #
    # @param [String] name
    #
    # @return [Index]
    #
    # @api private
    #
    def index(name)
      Index.new(connection, name)
    end

    # Return handler for indices
    #
    # @param [Enumerable<String>] names
    #
    # @return [Indices]
    #
    # @api private
    #
    def indices(names)
      Indices.new(connection, names)
    end

    # Return cluster health
    #
    # @param [Hash] options
    #
    # @return [Presenter::Health]
    #
    # @api private
    #
    def health(options = {})
      Command::Cluster::Health.run(self, options)
    end

    # Return path
    #
    # @return [Pathname]
    #
    # @api private
    #
    def path
      PATH
    end

    # Return handler for all indices
    #
    # @return [Indices::All]
    #
    # @api private
    #
    def all_indices
      Indices::All.new(connection)
    end
    memoize :all_indices

    # Build connection
    #
    # @return [Connection]
    #
    # @api private
    #
    def self.connect(*args)
      new(Connection.build(*args))
    end

  end # Cluster
end # Esearch