Contents

module Druid
  module Node
    class Broker
      QUERY_PATH = '/druid/v2'.freeze

      attr_reader :connection
      def initialize(config)
        @connection = Druid::Connection.new(config.broker_uri)
      end

      def query(query_object)
        response = connection.post(QUERY_PATH, query_object)
        raise QueryError unless response.code.to_i == 200
        JSON.parse(response.body)
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
jruby-druid-1.0.0.pre.rc4	lib/druid/node/broker.rb
jruby-druid-1.0.0.pre.rc3	lib/druid/node/broker.rb
jruby-druid-1.0.0.pre.rc2	lib/druid/node/broker.rb