Sha256: c56810852f687fa1b30a54902d19683c104ac47928297233002e07f6ea30d819
Contents?: true
Size: 735 Bytes
Versions: 22
Compression:
Stored size: 735 Bytes
Contents
require 'zk'
require 'timeout'
module Cellect
class NodeSet
include Celluloid
attr_accessor :zk, :state
def initialize(zk_url = nil)
@zk_url = zk_url
self.state = :initializing
after(0.001){ async.initialize_zk } # don't block waiting for ZK to connect
end
def initialize_zk
# don't let ZK hang the thread, just retry connection on restart
Timeout::timeout(5) do
self.zk = ZK.new zk_url, chroot: '/cellect'
end
setup
self.state = :ready
end
def ready?
state == :ready
end
protected
def zk_url
@zk_url || ENV.fetch('ZK_URL', 'localhost:2181')
end
def setup
end
end
end
Version data entries
22 entries across 22 versions & 2 rubygems