Sha256: 0cce7bf6ff5055df332fac4c7ea85bd6ec8a78806c301581560e9e345bc99e75
Contents?: true
Size: 1.77 KB
Versions: 31
Compression:
Stored size: 1.77 KB
Contents
module ZK
# A ruby-friendly wrapper around the low-level zookeeper drivers.
#
# You're probably looking for {Client::Base} and {Client::Threaded}.
#
# Once you've had a look there, take a look at {Client::Conveniences},
# {Client::StateMixin}, and {Client::Unixisms}
#
# @todo ACL support is pretty much unused currently.
# If anyone has suggestions, hints, use-cases, examples, etc. by all means please file a bug.
#
module Client
DEFAULT_TIMEOUT = 10 unless defined?(DEFAULT_TIMEOUT)
# @private
STATE_SYM_MAP = {
Zookeeper::ZOO_CLOSED_STATE => :closed,
Zookeeper::ZOO_EXPIRED_SESSION_STATE => :expired_session,
Zookeeper::ZOO_AUTH_FAILED_STATE => :auth_failed,
Zookeeper::ZOO_CONNECTING_STATE => :connecting,
Zookeeper::ZOO_CONNECTED_STATE => :connected,
Zookeeper::ZOO_ASSOCIATING_STATE => :associating,
}.freeze unless defined?(STATE_SYM_MAP)
class << self
# (see Threaded#initialize)
def new(*a, &b)
Threaded.new(*a, &b)
end
# @private
def assert_valid_chroot_str!(str)
return unless str
raise ChrootMustStartWithASlashError, str unless str.start_with?('/')
end
# Takes a connection string and returns an Array of [host, chroot_path].
# If the connection string is not chrooted, then chroot_path will be nil.
#
# @private
def split_chroot(str)
if idx = str.index('/')
host = str[0...idx]
chroot_path = str[idx..-1]
[host, chroot_path]
else
[str, nil]
end
end
end
end
end
require 'zk/client/state_mixin'
require 'zk/client/unixisms'
require 'zk/client/conveniences'
require 'zk/client/base'
require 'zk/client/threaded'
Version data entries
31 entries across 31 versions & 1 rubygems