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

   1 from typing import Any\r
   2 \r
   3 SYM_EMPTY = ...  # type: Any\r
   4 \r
   5 def list_or_args(keys, args): ...\r
   6 def timestamp_to_datetime(response): ...\r
   7 def string_keys_to_dict(key_string, callback): ...\r
   8 def dict_merge(*dicts): ...\r
   9 def parse_debug_object(response): ...\r
  10 def parse_object(response, infotype): ...\r
  11 def parse_info(response): ...\r
  12 \r
  13 SENTINEL_STATE_TYPES = ...  # type: Any\r
  14 \r
  15 def parse_sentinel_state(item): ...\r
  16 def parse_sentinel_master(response): ...\r
  17 def parse_sentinel_masters(response): ...\r
  18 def parse_sentinel_slaves_and_sentinels(response): ...\r
  19 def parse_sentinel_get_master(response): ...\r
  20 def pairs_to_dict(response): ...\r
  21 def pairs_to_dict_typed(response, type_info): ...\r
  22 def zset_score_pairs(response, **options): ...\r
  23 def sort_return_tuples(response, **options): ...\r
  24 def int_or_none(response): ...\r
  25 def float_or_none(response): ...\r
  26 def bool_ok(response): ...\r
  27 def parse_client_list(response, **options): ...\r
  28 def parse_config_get(response, **options): ...\r
  29 def parse_scan(response, **options): ...\r
  30 def parse_hscan(response, **options): ...\r
  31 def parse_zscan(response, **options): ...\r
  32 def parse_slowlog_get(response, **options): ...\r
  33 \r
  34 class StrictRedis:\r
  35     RESPONSE_CALLBACKS = ...  # type: Any\r
  36     @classmethod\r
  37     def from_url(cls, url, db=..., **kwargs): ...\r
  38     connection_pool = ...  # type: Any\r
  39     response_callbacks = ...  # type: Any\r
  40     def __init__(self, host=..., port=..., db=..., password=..., socket_timeout=..., socket_connect_timeout=..., socket_keepalive=..., socket_keepalive_options=..., connection_pool=..., unix_socket_path=..., encoding=..., encoding_errors=..., charset=..., errors=..., decode_responses=..., retry_on_timeout=..., ssl=..., ssl_keyfile=..., ssl_certfile=..., ssl_cert_reqs=..., ssl_ca_certs=...) -> None: ...\r
  41     def set_response_callback(self, command, callback): ...\r
  42     def pipeline(self, transaction=..., shard_hint=...): ...\r
  43     def transaction(self, func, *watches, **kwargs): ...\r
  44     def lock(self, name, timeout=..., sleep=..., blocking_timeout=..., lock_class=..., thread_local=...): ...\r
  45     def pubsub(self, **kwargs): ...\r
  46     def execute_command(self, *args, **options): ...\r
  47     def parse_response(self, connection, command_name, **options): ...\r
  48     def bgrewriteaof(self): ...\r
  49     def bgsave(self): ...\r
  50     def client_kill(self, address): ...\r
  51     def client_list(self): ...\r
  52     def client_getname(self): ...\r
  53     def client_setname(self, name): ...\r
  54     def config_get(self, pattern=...): ...\r
  55     def config_set(self, name, value): ...\r
  56     def config_resetstat(self): ...\r
  57     def config_rewrite(self): ...\r
  58     def dbsize(self): ...\r
  59     def debug_object(self, key): ...\r
  60     def echo(self, value): ...\r
  61     def flushall(self): ...\r
  62     def flushdb(self): ...\r
  63     def info(self, section=...): ...\r
  64     def lastsave(self): ...\r
  65     def object(self, infotype, key): ...\r
  66     def ping(self): ...\r
  67     def save(self): ...\r
  68     def sentinel(self, *args): ...\r
  69     def sentinel_get_master_addr_by_name(self, service_name): ...\r
  70     def sentinel_master(self, service_name): ...\r
  71     def sentinel_masters(self): ...\r
  72     def sentinel_monitor(self, name, ip, port, quorum): ...\r
  73     def sentinel_remove(self, name): ...\r
  74     def sentinel_sentinels(self, service_name): ...\r
  75     def sentinel_set(self, name, option, value): ...\r
  76     def sentinel_slaves(self, service_name): ...\r
  77     def shutdown(self): ...\r
  78     def slaveof(self, host=..., port=...): ...\r
  79     def slowlog_get(self, num=...): ...\r
  80     def slowlog_len(self): ...\r
  81     def slowlog_reset(self): ...\r
  82     def time(self): ...\r
  83     def append(self, key, value): ...\r
  84     def bitcount(self, key, start=..., end=...): ...\r
  85     def bitop(self, operation, dest, *keys): ...\r
  86     def bitpos(self, key, bit, start=..., end=...): ...\r
  87     def decr(self, name, amount=...): ...\r
  88     def delete(self, *names): ...\r
  89     def __delitem__(self, name): ...\r
  90     def dump(self, name): ...\r
  91     def exists(self, name): ...\r
  92     __contains__ = ...  # type: Any\r
  93     def expire(self, name, time): ...\r
  94     def expireat(self, name, when): ...\r
  95     def get(self, name): ...\r
  96     def __getitem__(self, name): ...\r
  97     def getbit(self, name, offset): ...\r
  98     def getrange(self, key, start, end): ...\r
  99     def getset(self, name, value): ...\r
 100     def incr(self, name, amount=...): ...\r
 101     def incrby(self, name, amount=...): ...\r
 102     def incrbyfloat(self, name, amount=...): ...\r
 103     def keys(self, pattern=...): ...\r
 104     def mget(self, keys, *args): ...\r
 105     def mset(self, *args, **kwargs): ...\r
 106     def msetnx(self, *args, **kwargs): ...\r
 107     def move(self, name, db): ...\r
 108     def persist(self, name): ...\r
 109     def pexpire(self, name, time): ...\r
 110     def pexpireat(self, name, when): ...\r
 111     def psetex(self, name, time_ms, value): ...\r
 112     def pttl(self, name): ...\r
 113     def randomkey(self): ...\r
 114     def rename(self, src, dst): ...\r
 115     def renamenx(self, src, dst): ...\r
 116     def restore(self, name, ttl, value): ...\r
 117     def set(self, name, value, ex=..., px=..., nx=..., xx=...): ...\r
 118     def __setitem__(self, name, value): ...\r
 119     def setbit(self, name, offset, value): ...\r
 120     def setex(self, name, time, value): ...\r
 121     def setnx(self, name, value): ...\r
 122     def setrange(self, name, offset, value): ...\r
 123     def strlen(self, name): ...\r
 124     def substr(self, name, start, end=...): ...\r
 125     def ttl(self, name): ...\r
 126     def type(self, name): ...\r
 127     def watch(self, *names): ...\r
 128     def unwatch(self): ...\r
 129     def blpop(self, keys, timeout=...): ...\r
 130     def brpop(self, keys, timeout=...): ...\r
 131     def brpoplpush(self, src, dst, timeout=...): ...\r
 132     def lindex(self, name, index): ...\r
 133     def linsert(self, name, where, refvalue, value): ...\r
 134     def llen(self, name): ...\r
 135     def lpop(self, name): ...\r
 136     def lpush(self, name, *values): ...\r
 137     def lpushx(self, name, value): ...\r
 138     def lrange(self, name, start, end): ...\r
 139     def lrem(self, name, count, value): ...\r
 140     def lset(self, name, index, value): ...\r
 141     def ltrim(self, name, start, end): ...\r
 142     def rpop(self, name): ...\r
 143     def rpoplpush(self, src, dst): ...\r
 144     def rpush(self, name, *values): ...\r
 145     def rpushx(self, name, value): ...\r
 146     def sort(self, name, start=..., num=..., by=..., get=..., desc=..., alpha=..., store=..., groups=...): ...\r
 147     def scan(self, cursor=..., match=..., count=...): ...\r
 148     def scan_iter(self, match=..., count=...): ...\r
 149     def sscan(self, name, cursor=..., match=..., count=...): ...\r
 150     def sscan_iter(self, name, match=..., count=...): ...\r
 151     def hscan(self, name, cursor=..., match=..., count=...): ...\r
 152     def hscan_iter(self, name, match=..., count=...): ...\r
 153     def zscan(self, name, cursor=..., match=..., count=..., score_cast_func=...): ...\r
 154     def zscan_iter(self, name, match=..., count=..., score_cast_func=...): ...\r
 155     def sadd(self, name, *values): ...\r
 156     def scard(self, name): ...\r
 157     def sdiff(self, keys, *args): ...\r
 158     def sdiffstore(self, dest, keys, *args): ...\r
 159     def sinter(self, keys, *args): ...\r
 160     def sinterstore(self, dest, keys, *args): ...\r
 161     def sismember(self, name, value): ...\r
 162     def smembers(self, name): ...\r
 163     def smove(self, src, dst, value): ...\r
 164     def spop(self, name): ...\r
 165     def srandmember(self, name, number=...): ...\r
 166     def srem(self, name, *values): ...\r
 167     def sunion(self, keys, *args): ...\r
 168     def sunionstore(self, dest, keys, *args): ...\r
 169     def zadd(self, name, *args, **kwargs): ...\r
 170     def zcard(self, name): ...\r
 171     def zcount(self, name, min, max): ...\r
 172     def zincrby(self, name, value, amount=...): ...\r
 173     def zinterstore(self, dest, keys, aggregate=...): ...\r
 174     def zlexcount(self, name, min, max): ...\r
 175     def zrange(self, name, start, end, desc=..., withscores=..., score_cast_func=...): ...\r
 176     def zrangebylex(self, name, min, max, start=..., num=...): ...\r
 177     def zrangebyscore(self, name, min, max, start=..., num=..., withscores=..., score_cast_func=...): ...\r
 178     def zrank(self, name, value): ...\r
 179     def zrem(self, name, *values): ...\r
 180     def zremrangebylex(self, name, min, max): ...\r
 181     def zremrangebyrank(self, name, min, max): ...\r
 182     def zremrangebyscore(self, name, min, max): ...\r
 183     def zrevrange(self, name, start, end, withscores=..., score_cast_func=...): ...\r
 184     def zrevrangebyscore(self, name, max, min, start=..., num=..., withscores=..., score_cast_func=...): ...\r
 185     def zrevrank(self, name, value): ...\r
 186     def zscore(self, name, value): ...\r
 187     def zunionstore(self, dest, keys, aggregate=...): ...\r
 188     def pfadd(self, name, *values): ...\r
 189     def pfcount(self, name): ...\r
 190     def pfmerge(self, dest, *sources): ...\r
 191     def hdel(self, name, *keys): ...\r
 192     def hexists(self, name, key): ...\r
 193     def hget(self, name, key): ...\r
 194     def hgetall(self, name): ...\r
 195     def hincrby(self, name, key, amount=...): ...\r
 196     def hincrbyfloat(self, name, key, amount=...): ...\r
 197     def hkeys(self, name): ...\r
 198     def hlen(self, name): ...\r
 199     def hset(self, name, key, value): ...\r
 200     def hsetnx(self, name, key, value): ...\r
 201     def hmset(self, name, mapping): ...\r
 202     def hmget(self, name, keys, *args): ...\r
 203     def hvals(self, name): ...\r
 204     def publish(self, channel, message): ...\r
 205     def eval(self, script, numkeys, *keys_and_args): ...\r
 206     def evalsha(self, sha, numkeys, *keys_and_args): ...\r
 207     def script_exists(self, *args): ...\r
 208     def script_flush(self): ...\r
 209     def script_kill(self): ...\r
 210     def script_load(self, script): ...\r
 211     def register_script(self, script): ...\r
 212 \r
 213 class Redis(StrictRedis):\r
 214     RESPONSE_CALLBACKS = ...  # type: Any\r
 215     def pipeline(self, transaction=..., shard_hint=...): ...\r
 216     def setex(self, name, value, time): ...\r
 217     def lrem(self, name, value, num=...): ...\r
 218     def zadd(self, name, *args, **kwargs): ...\r
 219 \r
 220 class PubSub:\r
 221     PUBLISH_MESSAGE_TYPES = ...  # type: Any\r
 222     UNSUBSCRIBE_MESSAGE_TYPES = ...  # type: Any\r
 223     connection_pool = ...  # type: Any\r
 224     shard_hint = ...  # type: Any\r
 225     ignore_subscribe_messages = ...  # type: Any\r
 226     connection = ...  # type: Any\r
 227     encoding = ...  # type: Any\r
 228     encoding_errors = ...  # type: Any\r
 229     decode_responses = ...  # type: Any\r
 230     def __init__(self, connection_pool, shard_hint=..., ignore_subscribe_messages=...) -> None: ...\r
 231     def __del__(self): ...\r
 232     channels = ...  # type: Any\r
 233     patterns = ...  # type: Any\r
 234     def reset(self): ...\r
 235     def close(self): ...\r
 236     def on_connect(self, connection): ...\r
 237     def encode(self, value): ...\r
 238     @property\r
 239     def subscribed(self): ...\r
 240     def execute_command(self, *args, **kwargs): ...\r
 241     def parse_response(self, block=...): ...\r
 242     def psubscribe(self, *args, **kwargs): ...\r
 243     def punsubscribe(self, *args): ...\r
 244     def subscribe(self, *args, **kwargs): ...\r
 245     def unsubscribe(self, *args): ...\r
 246     def listen(self): ...\r
 247     def get_message(self, ignore_subscribe_messages=...): ...\r
 248     def handle_message(self, response, ignore_subscribe_messages=...): ...\r
 249     def run_in_thread(self, sleep_time=...): ...\r
 250 \r
 251 class BasePipeline:\r
 252     UNWATCH_COMMANDS = ...  # type: Any\r
 253     connection_pool = ...  # type: Any\r
 254     connection = ...  # type: Any\r
 255     response_callbacks = ...  # type: Any\r
 256     transaction = ...  # type: Any\r
 257     shard_hint = ...  # type: Any\r
 258     watching = ...  # type: Any\r
 259     def __init__(self, connection_pool, response_callbacks, transaction, shard_hint) -> None: ...\r
 260     def __enter__(self): ...\r
 261     def __exit__(self, exc_type, exc_value, traceback): ...\r
 262     def __del__(self): ...\r
 263     def __len__(self): ...\r
 264     command_stack = ...  # type: Any\r
 265     scripts = ...  # type: Any\r
 266     explicit_transaction = ...  # type: Any\r
 267     def reset(self): ...\r
 268     def multi(self): ...\r
 269     def execute_command(self, *args, **kwargs): ...\r
 270     def immediate_execute_command(self, *args, **options): ...\r
 271     def pipeline_execute_command(self, *args, **options): ...\r
 272     def raise_first_error(self, commands, response): ...\r
 273     def annotate_exception(self, exception, number, command): ...\r
 274     def parse_response(self, connection, command_name, **options): ...\r
 275     def load_scripts(self): ...\r
 276     def execute(self, raise_on_error=...): ...\r
 277     def watch(self, *names): ...\r
 278     def unwatch(self): ...\r
 279     def script_load_for_pipeline(self, script): ...\r
 280 \r
 281 class StrictPipeline(BasePipeline, StrictRedis): ...\r
 282 class Pipeline(BasePipeline, Redis): ...\r
 283 \r
 284 class Script:\r
 285     registered_client = ...  # type: Any\r
 286     script = ...  # type: Any\r
 287     sha = ...  # type: Any\r
 288     def __init__(self, registered_client, script) -> None: ...\r
 289     def __call__(self, keys=..., args=..., client=...): ...\r