Module: Kazoo

Defined in:
lib/kazoo.rb,
lib/kazoo/cli.rb,
lib/kazoo/topic.rb,
lib/kazoo/broker.rb,
lib/kazoo/cluster.rb,
lib/kazoo/version.rb,
lib/kazoo/partition.rb,
lib/kazoo/cli/common.rb,
lib/kazoo/cli/topics.rb,
lib/kazoo/cli/cluster.rb,
lib/kazoo/cli/consumers.rb,
lib/kazoo/consumergroup.rb

Defined Under Namespace

Classes: Broker, CLI, Cluster, Consumergroup, Partition, Topic

Constant Summary collapse

Error = 
Class.new(StandardError)
ValidationError = 
Class.new(Kazoo::Error)
NoClusterRegistered = 
Class.new(Kazoo::Error)
ConsumerInstanceRegistrationFailed = 
Class.new(Kazoo::Error)
PartitionAlreadyClaimed = 
Class.new(Kazoo::Error)
ReleasePartitionFailure = 
Class.new(Kazoo::Error)
VERSION = 
"0.3.1"

Class Method Summary collapse

Class Method Details

.connect(zookeeper) ⇒ Object 



16
17
18
 
# File 'lib/kazoo.rb', line 16

def self.connect(zookeeper)
  Kazoo::Cluster.new(zookeeper)
end