Sha256: d7f2f97f49f2fe12d97c6c694bc57ecd6302dda62eff211ea3c25b53aa2d2b55

Contents?: true

Size: 659 Bytes

Versions: 2

Compression:

Stored size: 659 Bytes

Contents

module DruidDB
  class Client
    include DruidDB::Queries::Core
    include DruidDB::Queries::Datasources
    include DruidDB::Queries::Task

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

    def initialize(options = {})
      @config = DruidDB::Configuration.new(options)
      @zk = DruidDB::ZK.new(config)
      @broker = DruidDB::Node::Broker.new(config, zk)
      @coordinator = DruidDB::Node::Coordinator.new(config, zk)
      @overlord = DruidDB::Node::Overlord.new(config, zk)
      @writer = DruidDB::Writer.new(config, zk)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
druiddb-1.2.1 lib/druiddb/client.rb
druiddb-1.2.0 lib/druiddb/client.rb