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/subscription.rb,
lib/kazoo/cli/consumers.rb,
lib/kazoo/consumergroup.rb,
lib/kazoo/replica_assigner.rb

Defined Under Namespace

Classes: Broker, CLI, Cluster, Consumergroup, Partition, PatternSubscription, ReplicaAssigner, StaticSubscription, Subscription, Topic

Constant Summary collapse

Error = 
Class.new(StandardError)
ValidationError = 
Class.new(Kazoo::Error)
VersionNotSupported = 
Class.new(Kazoo::Error)
NoClusterRegistered = 
Class.new(Kazoo::Error)
TopicNotFound = 
Class.new(Kazoo::Error)
ConsumerInstanceRegistrationFailed = 
Class.new(Kazoo::Error)
PartitionAlreadyClaimed = 
Class.new(Kazoo::Error)
ReleasePartitionFailure = 
Class.new(Kazoo::Error)
InvalidSubscription = 
Class.new(Kazoo::Error)
InconsistentSubscriptions = 
Class.new(Kazoo::Error)
NoRunningInstances = 
Class.new(Kazoo::Error)
VERSION = 
"0.5.6"

Class Method Summary collapse

Class Method Details

.connect(zookeeper) ⇒ Object 



23
24
25
 
# File 'lib/kazoo.rb', line 23

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