--- /dev/null
+from typing import Any\r
+\r
+string_types = ... # type: Any\r
+bytes_types = ... # type: Any\r
+LOST_STATES = ... # type: Any\r
+ENVI_VERSION = ... # type: Any\r
+ENVI_VERSION_KEY = ... # type: Any\r
+log = ... # type: Any\r
+\r
+class KazooClient:\r
+ logger = ... # type: Any\r
+ handler = ... # type: Any\r
+ auth_data = ... # type: Any\r
+ default_acl = ... # type: Any\r
+ randomize_hosts = ... # type: Any\r
+ hosts = ... # type: Any\r
+ chroot = ... # type: Any\r
+ state = ... # type: Any\r
+ state_listeners = ... # type: Any\r
+ read_only = ... # type: Any\r
+ retry = ... # type: Any\r
+ Barrier = ... # type: Any\r
+ Counter = ... # type: Any\r
+ DoubleBarrier = ... # type: Any\r
+ ChildrenWatch = ... # type: Any\r
+ DataWatch = ... # type: Any\r
+ Election = ... # type: Any\r
+ NonBlockingLease = ... # type: Any\r
+ MultiNonBlockingLease = ... # type: Any\r
+ Lock = ... # type: Any\r
+ Party = ... # type: Any\r
+ Queue = ... # type: Any\r
+ LockingQueue = ... # type: Any\r
+ SetPartitioner = ... # type: Any\r
+ Semaphore = ... # type: Any\r
+ ShallowParty = ... # type: Any\r
+ def __init__(self, hosts=..., timeout=..., client_id=..., handler=..., default_acl=..., auth_data=..., read_only=..., randomize_hosts=..., connection_retry=..., command_retry=..., logger=..., **kwargs) -> None: ...\r
+ @property\r
+ def client_state(self): ...\r
+ @property\r
+ def client_id(self): ...\r
+ @property\r
+ def connected(self): ...\r
+ def set_hosts(self, hosts, randomize_hosts=...): ...\r
+ def add_listener(self, listener): ...\r
+ def remove_listener(self, listener): ...\r
+ def start(self, timeout=...): ...\r
+ def start_async(self): ...\r
+ def stop(self): ...\r
+ def restart(self): ...\r
+ def close(self): ...\r
+ def command(self, cmd=...): ...\r
+ def server_version(self, retries=...): ...\r
+ def add_auth(self, scheme, credential): ...\r
+ def add_auth_async(self, scheme, credential): ...\r
+ def unchroot(self, path): ...\r
+ def sync_async(self, path): ...\r
+ def sync(self, path): ...\r
+ def create(self, path, value=..., acl=..., ephemeral=..., sequence=..., makepath=...): ...\r
+ def create_async(self, path, value=..., acl=..., ephemeral=..., sequence=..., makepath=...): ...\r
+ def ensure_path(self, path, acl=...): ...\r
+ def ensure_path_async(self, path, acl=...): ...\r
+ def exists(self, path, watch=...): ...\r
+ def exists_async(self, path, watch=...): ...\r
+ def get(self, path, watch=...): ...\r
+ def get_async(self, path, watch=...): ...\r
+ def get_children(self, path, watch=..., include_data=...): ...\r
+ def get_children_async(self, path, watch=..., include_data=...): ...\r
+ def get_acls(self, path): ...\r
+ def get_acls_async(self, path): ...\r
+ def set_acls(self, path, acls, version=...): ...\r
+ def set_acls_async(self, path, acls, version=...): ...\r
+ def set(self, path, value, version=...): ...\r
+ def set_async(self, path, value, version=...): ...\r
+ def transaction(self): ...\r
+ def delete(self, path, version=..., recursive=...): ...\r
+ def delete_async(self, path, version=...): ...\r
+ def reconfig(self, joining, leaving, new_members, from_config=...): ...\r
+ def reconfig_async(self, joining, leaving, new_members, from_config): ...\r
+\r
+class TransactionRequest:\r
+ client = ... # type: Any\r
+ operations = ... # type: Any\r
+ committed = ... # type: Any\r
+ def __init__(self, client) -> None: ...\r
+ def create(self, path, value=..., acl=..., ephemeral=..., sequence=...): ...\r
+ def delete(self, path, version=...): ...\r
+ def set_data(self, path, value, version=...): ...\r
+ def check(self, path, version): ...\r
+ def commit_async(self): ...\r
+ def commit(self): ...\r
+ def __enter__(self): ...\r
+ def __exit__(self, exc_type, exc_value, exc_tb): ...\r
+\r
+class KazooState:\r
+ ...\r