Index

_ | A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | U | V | W | Z

_

__add__() (kazoo_sasl.recipe.counter.Counter method)
__call__() (kazoo_sasl.recipe.watchers.ChildrenWatch method)
(kazoo_sasl.recipe.watchers.DataWatch method)
(kazoo_sasl.retry.KazooRetry method)
__init__() (kazoo_sasl.recipe.barrier.Barrier method)
(kazoo_sasl.recipe.barrier.DoubleBarrier method)
(kazoo_sasl.recipe.counter.Counter method)
(kazoo_sasl.recipe.election.Election method)
(kazoo_sasl.recipe.lease.MultiNonBlockingLease method)
(kazoo_sasl.recipe.lease.NonBlockingLease method)
(kazoo_sasl.recipe.lock.Lock method)
(kazoo_sasl.recipe.lock.ReadLock method)
(kazoo_sasl.recipe.lock.Semaphore method)
(kazoo_sasl.recipe.lock.WriteLock method)
(kazoo_sasl.recipe.partitioner.SetPartitioner method)
(kazoo_sasl.recipe.party.Party method)
(kazoo_sasl.recipe.party.ShallowParty method)
(kazoo_sasl.recipe.queue.LockingQueue method)
(kazoo_sasl.recipe.queue.Queue method)
(kazoo_sasl.recipe.watchers.ChildrenWatch method)
(kazoo_sasl.recipe.watchers.DataWatch method)
(kazoo_sasl.recipe.watchers.PatientChildrenWatch method)
(kazoo_sasl.retry.KazooRetry method)
__iter__() (kazoo_sasl.recipe.party.Party method)
(kazoo_sasl.recipe.party.ShallowParty method)
__len__() (kazoo_sasl.recipe.party.Party method)
(kazoo_sasl.recipe.party.ShallowParty method)
(kazoo_sasl.recipe.queue.LockingQueue method)
(kazoo_sasl.recipe.queue.Queue method)
__sub__() (kazoo_sasl.recipe.counter.Counter method)

A

ACL (class in kazoo_sasl.security)
acl_version (kazoo_sasl.protocol.states.ZnodeStat attribute)
acquire() (kazoo_sasl.recipe.lock.Lock method)
(kazoo_sasl.recipe.lock.ReadLock method)
(kazoo_sasl.recipe.lock.Semaphore method)
(kazoo_sasl.recipe.lock.WriteLock method)
ACQUIRED (kazoo_sasl.recipe.partitioner.PartitionState attribute)
acquired (kazoo_sasl.recipe.partitioner.SetPartitioner attribute)
ALLOCATING (kazoo_sasl.recipe.partitioner.PartitionState attribute)
allocating (kazoo_sasl.recipe.partitioner.SetPartitioner attribute)
APIError
async_result() (kazoo_sasl.handlers.gevent.SequentialGeventHandler method)
(kazoo_sasl.handlers.threading.SequentialThreadingHandler method)
(kazoo_sasl.interfaces.IHandler method)
AsyncResult (class in kazoo_sasl.handlers.eventlet)
(class in kazoo_sasl.handlers.gevent)
(class in kazoo_sasl.handlers.threading)
AUTH_FAILED (kazoo_sasl.protocol.states.KeeperState attribute)
AuthFailedError

B

BadArgumentsError
BadVersionError
Barrier (class in kazoo_sasl.recipe.barrier)

C

Callback (class in kazoo_sasl.protocol.states)
cancel() (kazoo_sasl.handlers.gevent.AsyncResult method)
(kazoo_sasl.recipe.election.Election method)
(kazoo_sasl.recipe.lock.Lock method)
(kazoo_sasl.recipe.lock.ReadLock method)
(kazoo_sasl.recipe.lock.Semaphore method)
(kazoo_sasl.recipe.lock.WriteLock method)
cancelled() (kazoo_sasl.handlers.gevent.AsyncResult method)
CancelledError
capture_exceptions() (in module kazoo_sasl.handlers.utils)
CHANGED (kazoo_sasl.protocol.states.EventType attribute)
CHILD (kazoo_sasl.protocol.states.EventType attribute)
children_count (kazoo_sasl.protocol.states.ZnodeStat attribute)
ChildrenWatch (class in kazoo_sasl.recipe.watchers)
close() (kazoo_sasl.recipe.cache.TreeCache method)
ConfigurationError
CONNECTED (kazoo_sasl.protocol.states.KazooState attribute)
(kazoo_sasl.protocol.states.KeeperState attribute)
CONNECTED_RO (kazoo_sasl.protocol.states.KeeperState attribute)
CONNECTING (kazoo_sasl.protocol.states.KeeperState attribute)
ConnectionClosedError
ConnectionDropped
ConnectionLoss
consume() (kazoo_sasl.recipe.queue.LockingQueue method)
contenders() (kazoo_sasl.recipe.election.Election method)
(kazoo_sasl.recipe.lock.Lock method)
(kazoo_sasl.recipe.lock.ReadLock method)
(kazoo_sasl.recipe.lock.WriteLock method)
copy() (kazoo_sasl.retry.KazooRetry method)
Counter (class in kazoo_sasl.recipe.counter)
create() (kazoo_sasl.recipe.barrier.Barrier method)
create_connection() (kazoo_sasl.interfaces.IHandler method)
create_socket_pair() (in module kazoo_sasl.handlers.utils)
create_tcp_socket() (in module kazoo_sasl.handlers.utils)
CREATED (kazoo_sasl.protocol.states.EventType attribute)
created (kazoo_sasl.protocol.states.ZnodeStat attribute)
creation_transaction_id (kazoo_sasl.protocol.states.ZnodeStat attribute)

D

data (kazoo_sasl.recipe.cache.NodeData attribute)
data_length (kazoo_sasl.protocol.states.ZnodeStat attribute)
DataInconsistency
DataWatch (class in kazoo_sasl.recipe.watchers)
DELETED (kazoo_sasl.protocol.states.EventType attribute)
dispatch_callback() (kazoo_sasl.handlers.gevent.SequentialGeventHandler method)
(kazoo_sasl.handlers.threading.SequentialThreadingHandler method)
(kazoo_sasl.interfaces.IHandler method)
done() (kazoo_sasl.handlers.gevent.AsyncResult method)
DoubleBarrier (class in kazoo_sasl.recipe.barrier)

E

Election (class in kazoo_sasl.recipe.election)
enter() (kazoo_sasl.recipe.barrier.DoubleBarrier method)
event_data (kazoo_sasl.recipe.cache.TreeEvent attribute)
event_object() (kazoo_sasl.handlers.gevent.SequentialGeventHandler method)
(kazoo_sasl.handlers.threading.SequentialThreadingHandler method)
(kazoo_sasl.interfaces.IHandler method)
event_type (kazoo_sasl.recipe.cache.TreeEvent attribute)
EventType (class in kazoo_sasl.protocol.states)
exc_info (kazoo_sasl.handlers.gevent.AsyncResult attribute)
exception (kazoo_sasl.handlers.gevent.AsyncResult attribute)
(kazoo_sasl.interfaces.IAsyncResult attribute)
EXPIRED_SESSION (kazoo_sasl.protocol.states.KeeperState attribute)

F

failed (kazoo_sasl.recipe.partitioner.SetPartitioner attribute)
FAILURE (kazoo_sasl.recipe.partitioner.PartitionState attribute)
finish() (kazoo_sasl.recipe.partitioner.SetPartitioner method)
ForceRetryError

G

get() (kazoo_sasl.handlers.gevent.AsyncResult method)
(kazoo_sasl.interfaces.IAsyncResult method)
(kazoo_sasl.recipe.queue.LockingQueue method)
(kazoo_sasl.recipe.queue.Queue method)
get_children() (kazoo_sasl.recipe.cache.TreeCache method)
get_data() (kazoo_sasl.recipe.cache.TreeCache method)
get_nowait() (kazoo_sasl.handlers.gevent.AsyncResult method)
(kazoo_sasl.interfaces.IAsyncResult method)

H

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

I

IAsyncResult (class in kazoo_sasl.interfaces)
Id (class in kazoo_sasl.security)
IHandler (class in kazoo_sasl.interfaces)
InterruptedError
InvalidACLError
InvalidCallbackError

J

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

K

kazoo_sasl.exceptions (module)
kazoo_sasl.handlers.eventlet (module)
kazoo_sasl.handlers.gevent (module)
kazoo_sasl.handlers.threading (module)
kazoo_sasl.handlers.utils (module)
kazoo_sasl.interfaces (module)
kazoo_sasl.protocol.states (module)
kazoo_sasl.recipe.barrier (module)
kazoo_sasl.recipe.cache (module)
kazoo_sasl.recipe.counter (module)
kazoo_sasl.recipe.election (module)
kazoo_sasl.recipe.lease (module)
kazoo_sasl.recipe.lock (module)
kazoo_sasl.recipe.partitioner (module)
kazoo_sasl.recipe.party (module)
kazoo_sasl.recipe.queue (module)
kazoo_sasl.recipe.watchers (module)
kazoo_sasl.retry (module)
kazoo_sasl.security (module)
KazooException
KazooRetry (class in kazoo_sasl.retry)
KazooState (class in kazoo_sasl.protocol.states)
KeeperState (class in kazoo_sasl.protocol.states)

L

last_modified (kazoo_sasl.protocol.states.ZnodeStat attribute)
last_modified_transaction_id (kazoo_sasl.protocol.states.ZnodeStat attribute)
lease_holders() (kazoo_sasl.recipe.lock.Semaphore method)
leave() (kazoo_sasl.recipe.barrier.DoubleBarrier method)
(kazoo_sasl.recipe.party.Party method)
(kazoo_sasl.recipe.party.ShallowParty method)
listen() (kazoo_sasl.recipe.cache.TreeCache method)
listen_fault() (kazoo_sasl.recipe.cache.TreeCache method)
Lock (class in kazoo_sasl.recipe.lock)
lock_object() (kazoo_sasl.handlers.gevent.SequentialGeventHandler method)
(kazoo_sasl.handlers.threading.SequentialThreadingHandler method)
(kazoo_sasl.interfaces.IHandler method)
LockingQueue (class in kazoo_sasl.recipe.queue)
LockTimeout
LOST (kazoo_sasl.protocol.states.KazooState attribute)

M

make() (kazoo_sasl.recipe.cache.NodeData class method)
(kazoo_sasl.recipe.cache.TreeEvent class method)
make_acl() (in module kazoo_sasl.security)
make_digest_acl() (in module kazoo_sasl.security)
make_digest_acl_credential() (in module kazoo_sasl.security)
MarshallingError
MultiNonBlockingLease (class in kazoo_sasl.recipe.lease)

N

name (kazoo_sasl.interfaces.IHandler attribute)
NoAuthError
NoChildrenForEphemeralsError
NodeData (class in kazoo_sasl.recipe.cache)
NodeExistsError
NonBlockingLease (class in kazoo_sasl.recipe.lease)
NONE (kazoo_sasl.protocol.states.EventType attribute)
NoNodeError
NotEmptyError
NotReadOnlyCallError

O

OperationTimeoutError
owner_session_id (kazoo_sasl.protocol.states.ZnodeStat attribute)

P

PartitionState (class in kazoo_sasl.recipe.partitioner)
Party (class in kazoo_sasl.recipe.party)
path (kazoo_sasl.protocol.states.WatchedEvent attribute)
(kazoo_sasl.recipe.cache.NodeData attribute)
PatientChildrenWatch (class in kazoo_sasl.recipe.watchers)
put() (kazoo_sasl.recipe.queue.LockingQueue method)
(kazoo_sasl.recipe.queue.Queue method)
put_all() (kazoo_sasl.recipe.queue.LockingQueue method)

Q

Queue (class in kazoo_sasl.recipe.queue)
queue_empty (kazoo_sasl.handlers.eventlet.SequentialEventletHandler attribute)
(kazoo_sasl.handlers.gevent.SequentialGeventHandler attribute)
(kazoo_sasl.handlers.threading.SequentialThreadingHandler attribute)
queue_impl (kazoo_sasl.handlers.eventlet.SequentialEventletHandler attribute)
(kazoo_sasl.handlers.gevent.SequentialGeventHandler attribute)
(kazoo_sasl.handlers.threading.SequentialThreadingHandler attribute)

R

rawlink() (kazoo_sasl.interfaces.IAsyncResult method)
ReadLock (class in kazoo_sasl.recipe.lock)
ready() (kazoo_sasl.handlers.gevent.AsyncResult method)
(kazoo_sasl.interfaces.IAsyncResult method)
RELEASE (kazoo_sasl.recipe.partitioner.PartitionState attribute)
release (kazoo_sasl.recipe.partitioner.SetPartitioner attribute)
release() (kazoo_sasl.recipe.lock.Lock method)
(kazoo_sasl.recipe.lock.ReadLock method)
(kazoo_sasl.recipe.lock.Semaphore method)
(kazoo_sasl.recipe.lock.WriteLock method)
(kazoo_sasl.recipe.queue.LockingQueue method)
release_set() (kazoo_sasl.recipe.partitioner.SetPartitioner method)
remove() (kazoo_sasl.recipe.barrier.Barrier method)
reset() (kazoo_sasl.retry.KazooRetry method)
result() (kazoo_sasl.handlers.gevent.AsyncResult method)
RetryFailedError
rlock_object() (kazoo_sasl.handlers.gevent.SequentialGeventHandler method)
(kazoo_sasl.handlers.threading.SequentialThreadingHandler method)
(kazoo_sasl.interfaces.IHandler method)
RolledBackError
run() (kazoo_sasl.recipe.election.Election method)
RuntimeInconsistency

S

select() (kazoo_sasl.interfaces.IHandler method)
Semaphore (class in kazoo_sasl.recipe.lock)
SequentialEventletHandler (class in kazoo_sasl.handlers.eventlet)
SequentialGeventHandler (class in kazoo_sasl.handlers.gevent)
SequentialThreadingHandler (class in kazoo_sasl.handlers.threading)
SessionExpiredError
SessionMovedError
set() (kazoo_sasl.handlers.gevent.AsyncResult method)
(kazoo_sasl.interfaces.IAsyncResult method)
set_exception() (kazoo_sasl.handlers.gevent.AsyncResult method)
(kazoo_sasl.interfaces.IAsyncResult method)
set_result() (kazoo_sasl.handlers.gevent.AsyncResult method)
SetPartitioner (class in kazoo_sasl.recipe.partitioner)
ShallowParty (class in kazoo_sasl.recipe.party)
sleep_func (kazoo_sasl.interfaces.IHandler attribute)
sleep_func() (kazoo_sasl.handlers.gevent.SequentialGeventHandler static method)
(kazoo_sasl.handlers.threading.SequentialThreadingHandler method)
socket() (kazoo_sasl.interfaces.IHandler method)
spawn() (kazoo_sasl.handlers.gevent.SequentialGeventHandler method)
(kazoo_sasl.interfaces.IHandler method)
start() (kazoo_sasl.handlers.gevent.SequentialGeventHandler method)
(kazoo_sasl.handlers.threading.SequentialThreadingHandler method)
(kazoo_sasl.interfaces.IHandler method)
(kazoo_sasl.recipe.cache.TreeCache method)
(kazoo_sasl.recipe.watchers.PatientChildrenWatch method)
stat (kazoo_sasl.recipe.cache.NodeData attribute)
state (kazoo_sasl.protocol.states.WatchedEvent attribute)
stop() (kazoo_sasl.handlers.gevent.SequentialGeventHandler method)
(kazoo_sasl.handlers.threading.SequentialThreadingHandler method)
(kazoo_sasl.interfaces.IHandler method)
successful() (kazoo_sasl.handlers.gevent.AsyncResult method)
(kazoo_sasl.interfaces.IAsyncResult method)
SUSPENDED (kazoo_sasl.protocol.states.KazooState attribute)
SystemZookeeperError

T

timeout_exception (kazoo_sasl.interfaces.IHandler attribute)
TreeCache (class in kazoo_sasl.recipe.cache)
TreeEvent (class in kazoo_sasl.recipe.cache)
type (kazoo_sasl.protocol.states.WatchedEvent attribute)

U

UnimplementedError
unlink() (kazoo_sasl.interfaces.IAsyncResult method)

V

value (kazoo_sasl.handlers.gevent.AsyncResult attribute)
(kazoo_sasl.interfaces.IAsyncResult attribute)
version (kazoo_sasl.protocol.states.ZnodeStat attribute)

W

wait() (kazoo_sasl.handlers.gevent.AsyncResult method)
(kazoo_sasl.interfaces.IAsyncResult method)
(kazoo_sasl.recipe.barrier.Barrier method)
wait_for_acquire() (kazoo_sasl.recipe.partitioner.SetPartitioner method)
WatchedEvent (class in kazoo_sasl.protocol.states)
wrap() (in module kazoo_sasl.handlers.utils)
WriteLock (class in kazoo_sasl.recipe.lock)
WriterNotClosedException

Z

ZnodeStat (class in kazoo_sasl.protocol.states)
Zookeeper
ZookeeperError
ZookeeperStoppedError