.config/coc/extensions/coc-python-data/languageServer.0.5.59/Typeshed/third_party/2/kazoo/client.pyi

   1 from typing import Any\r
   2 \r
   3 string_types = ...  # type: Any\r
   4 bytes_types = ...  # type: Any\r
   5 LOST_STATES = ...  # type: Any\r
   6 ENVI_VERSION = ...  # type: Any\r
   7 ENVI_VERSION_KEY = ...  # type: Any\r
   8 log = ...  # type: Any\r
   9 \r
  10 class KazooClient:\r
  11     logger = ...  # type: Any\r
  12     handler = ...  # type: Any\r
  13     auth_data = ...  # type: Any\r
  14     default_acl = ...  # type: Any\r
  15     randomize_hosts = ...  # type: Any\r
  16     hosts = ...  # type: Any\r
  17     chroot = ...  # type: Any\r
  18     state = ...  # type: Any\r
  19     state_listeners = ...  # type: Any\r
  20     read_only = ...  # type: Any\r
  21     retry = ...  # type: Any\r
  22     Barrier = ...  # type: Any\r
  23     Counter = ...  # type: Any\r
  24     DoubleBarrier = ...  # type: Any\r
  25     ChildrenWatch = ...  # type: Any\r
  26     DataWatch = ...  # type: Any\r
  27     Election = ...  # type: Any\r
  28     NonBlockingLease = ...  # type: Any\r
  29     MultiNonBlockingLease = ...  # type: Any\r
  30     Lock = ...  # type: Any\r
  31     Party = ...  # type: Any\r
  32     Queue = ...  # type: Any\r
  33     LockingQueue = ...  # type: Any\r
  34     SetPartitioner = ...  # type: Any\r
  35     Semaphore = ...  # type: Any\r
  36     ShallowParty = ...  # type: Any\r
  37     def __init__(self, hosts=..., timeout=..., client_id=..., handler=..., default_acl=..., auth_data=..., read_only=..., randomize_hosts=..., connection_retry=..., command_retry=..., logger=..., **kwargs) -> None: ...\r
  38     @property\r
  39     def client_state(self): ...\r
  40     @property\r
  41     def client_id(self): ...\r
  42     @property\r
  43     def connected(self): ...\r
  44     def set_hosts(self, hosts, randomize_hosts=...): ...\r
  45     def add_listener(self, listener): ...\r
  46     def remove_listener(self, listener): ...\r
  47     def start(self, timeout=...): ...\r
  48     def start_async(self): ...\r
  49     def stop(self): ...\r
  50     def restart(self): ...\r
  51     def close(self): ...\r
  52     def command(self, cmd=...): ...\r
  53     def server_version(self, retries=...): ...\r
  54     def add_auth(self, scheme, credential): ...\r
  55     def add_auth_async(self, scheme, credential): ...\r
  56     def unchroot(self, path): ...\r
  57     def sync_async(self, path): ...\r
  58     def sync(self, path): ...\r
  59     def create(self, path, value=..., acl=..., ephemeral=..., sequence=..., makepath=...): ...\r
  60     def create_async(self, path, value=..., acl=..., ephemeral=..., sequence=..., makepath=...): ...\r
  61     def ensure_path(self, path, acl=...): ...\r
  62     def ensure_path_async(self, path, acl=...): ...\r
  63     def exists(self, path, watch=...): ...\r
  64     def exists_async(self, path, watch=...): ...\r
  65     def get(self, path, watch=...): ...\r
  66     def get_async(self, path, watch=...): ...\r
  67     def get_children(self, path, watch=..., include_data=...): ...\r
  68     def get_children_async(self, path, watch=..., include_data=...): ...\r
  69     def get_acls(self, path): ...\r
  70     def get_acls_async(self, path): ...\r
  71     def set_acls(self, path, acls, version=...): ...\r
  72     def set_acls_async(self, path, acls, version=...): ...\r
  73     def set(self, path, value, version=...): ...\r
  74     def set_async(self, path, value, version=...): ...\r
  75     def transaction(self): ...\r
  76     def delete(self, path, version=..., recursive=...): ...\r
  77     def delete_async(self, path, version=...): ...\r
  78     def reconfig(self, joining, leaving, new_members, from_config=...): ...\r
  79     def reconfig_async(self, joining, leaving, new_members, from_config): ...\r
  80 \r
  81 class TransactionRequest:\r
  82     client = ...  # type: Any\r
  83     operations = ...  # type: Any\r
  84     committed = ...  # type: Any\r
  85     def __init__(self, client) -> None: ...\r
  86     def create(self, path, value=..., acl=..., ephemeral=..., sequence=...): ...\r
  87     def delete(self, path, version=...): ...\r
  88     def set_data(self, path, value, version=...): ...\r
  89     def check(self, path, version): ...\r
  90     def commit_async(self): ...\r
  91     def commit(self): ...\r
  92     def __enter__(self): ...\r
  93     def __exit__(self, exc_type, exc_value, exc_tb): ...\r
  94 \r
  95 class KazooState:\r
  96     ...\r