Contents

module Druid
  module Writer
    module Tranquilizer
      class Curator
        class << self
          def build(config)
            bounded_retry = org.apache.curator.retry.BoundedExponentialBackoffRetry.new(100, 30000, 29)
            CuratorFrameworkFactory.
              builder.
              connectString(config.curator_uri).
              retryPolicy(bounded_retry).
              build
          end
        end
      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/writer/tranquilizer/curator.rb
jruby-druid-1.0.0.pre.rc3	lib/druid/writer/tranquilizer/curator.rb
jruby-druid-1.0.0.pre.rc2	lib/druid/writer/tranquilizer/curator.rb