Index

_

__add__() (kazoo.recipe.counter.Counter method) __call__() (kazoo.retry.KazooRetry method) __init__() (kazoo.recipe.barrier.Barrier method) (kazoo.recipe.barrier.DoubleBarrier method) (kazoo.recipe.counter.Counter method) (kazoo.recipe.election.Election method) (kazoo.recipe.lease.MultiNonBlockingLease method) (kazoo.recipe.lease.NonBlockingLease method) (kazoo.recipe.party.Party method) (kazoo.recipe.party.ShallowParty method) (kazoo.recipe.queue.LockingQueue method) (kazoo.recipe.queue.Queue method) (kazoo.retry.KazooRetry method)

__iter__() (kazoo.recipe.party.Party method) (kazoo.recipe.party.ShallowParty method) __len__() (kazoo.recipe.party.Party method) (kazoo.recipe.party.ShallowParty method) (kazoo.recipe.queue.LockingQueue method) (kazoo.recipe.queue.Queue method) __sub__() (kazoo.recipe.counter.Counter method)

A

ACL (class in kazoo.security) acl_version (kazoo.protocol.states.ZnodeStat attribute) APIError async_result() (kazoo.handlers.threading.SequentialThreadingHandler method) (kazoo.interfaces.IHandler method)

AsyncResult (class in kazoo.handlers.threading) AUTH_FAILED (kazoo.protocol.states.KeeperState attribute) AuthFailedError

B

BadArgumentsError

BadVersionError Barrier (class in kazoo.recipe.barrier)

C

Callback (class in kazoo.protocol.states) cancel() (kazoo.recipe.election.Election method) CancelledError capture_exceptions() (in module kazoo.handlers.utils) CHANGED (kazoo.protocol.states.EventType attribute) CHILD (kazoo.protocol.states.EventType attribute) children_count (kazoo.protocol.states.ZnodeStat attribute) ConfigurationError CONNECTED (kazoo.protocol.states.KazooState attribute) (kazoo.protocol.states.KeeperState attribute) CONNECTED_RO (kazoo.protocol.states.KeeperState attribute) CONNECTING (kazoo.protocol.states.KeeperState attribute) ConnectionClosedError

ConnectionDropped ConnectionLoss consume() (kazoo.recipe.queue.LockingQueue method) contenders() (kazoo.recipe.election.Election method) copy() (kazoo.retry.KazooRetry method) Counter (class in kazoo.recipe.counter) create() (kazoo.recipe.barrier.Barrier method) create_connection() (kazoo.interfaces.IHandler method) create_socket_pair() (in module kazoo.handlers.utils) create_tcp_socket() (in module kazoo.handlers.utils) CREATED (kazoo.protocol.states.EventType attribute) created (kazoo.protocol.states.ZnodeStat attribute) creation_transaction_id (kazoo.protocol.states.ZnodeStat attribute)

D

data_length (kazoo.protocol.states.ZnodeStat attribute) DataInconsistency DELETED (kazoo.protocol.states.EventType attribute)

dispatch_callback() (kazoo.handlers.threading.SequentialThreadingHandler method) (kazoo.interfaces.IHandler method) DoubleBarrier (class in kazoo.recipe.barrier)

E

Election (class in kazoo.recipe.election) enter() (kazoo.recipe.barrier.DoubleBarrier method) event_object() (kazoo.handlers.threading.SequentialThreadingHandler method) (kazoo.interfaces.IHandler method)

EventType (class in kazoo.protocol.states) exception (kazoo.interfaces.IAsyncResult attribute) EXPIRED_SESSION (kazoo.protocol.states.KeeperState attribute)

F

ForceRetryError

G

get() (kazoo.interfaces.IAsyncResult method) (kazoo.recipe.queue.LockingQueue method) (kazoo.recipe.queue.Queue method)

get_nowait() (kazoo.interfaces.IAsyncResult method)

H

holds_lock() (kazoo.recipe.queue.LockingQueue method)

I

IAsyncResult (class in kazoo.interfaces) Id (class in kazoo.security) IHandler (class in kazoo.interfaces)

InterruptedError InvalidACLError InvalidCallbackError

J

join() (kazoo.recipe.party.Party method) (kazoo.recipe.party.ShallowParty method)

K

kazoo.exceptions module kazoo.handlers.threading module kazoo.handlers.utils module kazoo.interfaces module kazoo.protocol.states module kazoo.recipe.barrier module kazoo.recipe.counter module kazoo.recipe.election module

kazoo.recipe.lease module kazoo.recipe.party module kazoo.recipe.queue module kazoo.retry module kazoo.security module KazooException KazooRetry (class in kazoo.retry) KazooState (class in kazoo.protocol.states) KeeperState (class in kazoo.protocol.states)

L

last_modified (kazoo.protocol.states.ZnodeStat attribute) last_modified_transaction_id (kazoo.protocol.states.ZnodeStat attribute) leave() (kazoo.recipe.barrier.DoubleBarrier method) (kazoo.recipe.party.Party method) (kazoo.recipe.party.ShallowParty method)

lock_object() (kazoo.handlers.threading.SequentialThreadingHandler method) (kazoo.interfaces.IHandler method) LockingQueue (class in kazoo.recipe.queue) LockTimeout LOST (kazoo.protocol.states.KazooState attribute)

M

make_acl() (in module kazoo.security) make_digest_acl() (in module kazoo.security) make_digest_acl_credential() (in module kazoo.security) MarshallingError module kazoo.exceptions kazoo.handlers.threading kazoo.handlers.utils kazoo.interfaces kazoo.protocol.states kazoo.recipe.barrier kazoo.recipe.counter kazoo.recipe.election kazoo.recipe.lease kazoo.recipe.party kazoo.recipe.queue kazoo.retry kazoo.security

MultiNonBlockingLease (class in kazoo.recipe.lease)

N

name (kazoo.interfaces.IHandler attribute) NoAuthError NoChildrenForEphemeralsError NodeExistsError

NonBlockingLease (class in kazoo.recipe.lease) NONE (kazoo.protocol.states.EventType attribute) NoNodeError NotEmptyError NotReadOnlyCallError

O

OperationTimeoutError

owner_session_id (kazoo.protocol.states.ZnodeStat attribute)

P

Party (class in kazoo.recipe.party) path (kazoo.protocol.states.WatchedEvent attribute)

put() (kazoo.recipe.queue.LockingQueue method) (kazoo.recipe.queue.Queue method) put_all() (kazoo.recipe.queue.LockingQueue method)

Q

Queue (class in kazoo.recipe.queue)

queue_empty (kazoo.handlers.threading.SequentialThreadingHandler attribute) queue_impl (kazoo.handlers.threading.SequentialThreadingHandler attribute)

R

rawlink() (kazoo.interfaces.IAsyncResult method) ready() (kazoo.interfaces.IAsyncResult method) release() (kazoo.recipe.queue.LockingQueue method) remove() (kazoo.recipe.barrier.Barrier method) reset() (kazoo.retry.KazooRetry method)

RetryFailedError rlock_object() (kazoo.handlers.threading.SequentialThreadingHandler method) (kazoo.interfaces.IHandler method) RolledBackError run() (kazoo.recipe.election.Election method) RuntimeInconsistency

S

select() (kazoo.interfaces.IHandler method) SequentialThreadingHandler (class in kazoo.handlers.threading) SessionExpiredError SessionMovedError set() (kazoo.interfaces.IAsyncResult method) set_exception() (kazoo.interfaces.IAsyncResult method) ShallowParty (class in kazoo.recipe.party) sleep_func (kazoo.interfaces.IHandler attribute) sleep_func() (kazoo.handlers.threading.SequentialThreadingHandler static method)

socket() (kazoo.interfaces.IHandler method) spawn() (kazoo.interfaces.IHandler method) start() (kazoo.handlers.threading.SequentialThreadingHandler method) (kazoo.interfaces.IHandler method) state (kazoo.protocol.states.WatchedEvent attribute) stop() (kazoo.handlers.threading.SequentialThreadingHandler method) (kazoo.interfaces.IHandler method) successful() (kazoo.interfaces.IAsyncResult method) SUSPENDED (kazoo.protocol.states.KazooState attribute) SystemZookeeperError

T

timeout_exception (kazoo.handlers.threading.SequentialThreadingHandler attribute) (kazoo.interfaces.IHandler attribute)

type (kazoo.protocol.states.WatchedEvent attribute)

U

UnimplementedError

unlink() (kazoo.interfaces.IAsyncResult method)

V

value (kazoo.interfaces.IAsyncResult attribute)

version (kazoo.protocol.states.ZnodeStat attribute)

W

wait() (kazoo.interfaces.IAsyncResult method) (kazoo.recipe.barrier.Barrier method)

WatchedEvent (class in kazoo.protocol.states) wrap() (in module kazoo.handlers.utils) WriterNotClosedException

Z

ZnodeStat (class in kazoo.protocol.states) Zookeeper

ZookeeperError ZookeeperStoppedError