Sha256: b2e84b9a8381d9f55d900ee2f7fe17719955c38972a4844048d60f34f6de6075

Contents?: true

Size: 703 Bytes

Versions: 2

Compression:

Stored size: 703 Bytes

Contents

module Druid
  class Client
    include Druid::Logging
    include Druid::Queries::Core
    include Druid::Queries::Datasource
    include Druid::Queries::Task

    attr_reader :broker,
                :config,
                :coordinator,
                :overlord,
                :writer

    def initialize(options = {})
      @config = Druid::Configuration.new(options)
      @broker = Druid::Node::Broker.new(config)
      @coordinator = Druid::Node::Coordinator.new(config)
      setup_logger
      @overlord = Druid::Node::Overlord.new(config)
      @writer = Druid::Writer::Base.new(config)
    end

    private

    def setup_logger
      logger.set_level(config.log_level)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
jruby-druid-1.0.0.pre.rc4 lib/druid/client.rb
jruby-druid-1.0.0.pre.rc3 lib/druid/client.rb