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

Version	Path
zk-1.5.3	lib/zk/client.rb
zk-1.5.2	lib/zk/client.rb
zk-1.5.1	lib/zk/client.rb
zk-1.5.0	lib/zk/client.rb
zk-1.4.2	lib/zk/client.rb
zk-1.4.1	lib/zk/client.rb
zk-1.4.0	lib/zk/client.rb
zk-1.3.1	lib/zk/client.rb
zk-1.3.0	lib/zk/client.rb
zk-1.2.0	lib/zk/client.rb
zk-1.1.1	lib/zk/client.rb