--- /dev/null
+from typing import Any\r
+\r
+SYM_EMPTY = ... # type: Any\r
+\r
+def list_or_args(keys, args): ...\r
+def timestamp_to_datetime(response): ...\r
+def string_keys_to_dict(key_string, callback): ...\r
+def dict_merge(*dicts): ...\r
+def parse_debug_object(response): ...\r
+def parse_object(response, infotype): ...\r
+def parse_info(response): ...\r
+\r
+SENTINEL_STATE_TYPES = ... # type: Any\r
+\r
+def parse_sentinel_state(item): ...\r
+def parse_sentinel_master(response): ...\r
+def parse_sentinel_masters(response): ...\r
+def parse_sentinel_slaves_and_sentinels(response): ...\r
+def parse_sentinel_get_master(response): ...\r
+def pairs_to_dict(response): ...\r
+def pairs_to_dict_typed(response, type_info): ...\r
+def zset_score_pairs(response, **options): ...\r
+def sort_return_tuples(response, **options): ...\r
+def int_or_none(response): ...\r
+def float_or_none(response): ...\r
+def bool_ok(response): ...\r
+def parse_client_list(response, **options): ...\r
+def parse_config_get(response, **options): ...\r
+def parse_scan(response, **options): ...\r
+def parse_hscan(response, **options): ...\r
+def parse_zscan(response, **options): ...\r
+def parse_slowlog_get(response, **options): ...\r
+\r
+class StrictRedis:\r
+ RESPONSE_CALLBACKS = ... # type: Any\r
+ @classmethod\r
+ def from_url(cls, url, db=..., **kwargs): ...\r
+ connection_pool = ... # type: Any\r
+ response_callbacks = ... # type: Any\r
+ 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
+ def set_response_callback(self, command, callback): ...\r
+ def pipeline(self, transaction=..., shard_hint=...): ...\r
+ def transaction(self, func, *watches, **kwargs): ...\r
+ def lock(self, name, timeout=..., sleep=..., blocking_timeout=..., lock_class=..., thread_local=...): ...\r
+ def pubsub(self, **kwargs): ...\r
+ def execute_command(self, *args, **options): ...\r
+ def parse_response(self, connection, command_name, **options): ...\r
+ def bgrewriteaof(self): ...\r
+ def bgsave(self): ...\r
+ def client_kill(self, address): ...\r
+ def client_list(self): ...\r
+ def client_getname(self): ...\r
+ def client_setname(self, name): ...\r
+ def config_get(self, pattern=...): ...\r
+ def config_set(self, name, value): ...\r
+ def config_resetstat(self): ...\r
+ def config_rewrite(self): ...\r
+ def dbsize(self): ...\r
+ def debug_object(self, key): ...\r
+ def echo(self, value): ...\r
+ def flushall(self): ...\r
+ def flushdb(self): ...\r
+ def info(self, section=...): ...\r
+ def lastsave(self): ...\r
+ def object(self, infotype, key): ...\r
+ def ping(self): ...\r
+ def save(self): ...\r
+ def sentinel(self, *args): ...\r
+ def sentinel_get_master_addr_by_name(self, service_name): ...\r
+ def sentinel_master(self, service_name): ...\r
+ def sentinel_masters(self): ...\r
+ def sentinel_monitor(self, name, ip, port, quorum): ...\r
+ def sentinel_remove(self, name): ...\r
+ def sentinel_sentinels(self, service_name): ...\r
+ def sentinel_set(self, name, option, value): ...\r
+ def sentinel_slaves(self, service_name): ...\r
+ def shutdown(self): ...\r
+ def slaveof(self, host=..., port=...): ...\r
+ def slowlog_get(self, num=...): ...\r
+ def slowlog_len(self): ...\r
+ def slowlog_reset(self): ...\r
+ def time(self): ...\r
+ def append(self, key, value): ...\r
+ def bitcount(self, key, start=..., end=...): ...\r
+ def bitop(self, operation, dest, *keys): ...\r
+ def bitpos(self, key, bit, start=..., end=...): ...\r
+ def decr(self, name, amount=...): ...\r
+ def delete(self, *names): ...\r
+ def __delitem__(self, name): ...\r
+ def dump(self, name): ...\r
+ def exists(self, name): ...\r
+ __contains__ = ... # type: Any\r
+ def expire(self, name, time): ...\r
+ def expireat(self, name, when): ...\r
+ def get(self, name): ...\r
+ def __getitem__(self, name): ...\r
+ def getbit(self, name, offset): ...\r
+ def getrange(self, key, start, end): ...\r
+ def getset(self, name, value): ...\r
+ def incr(self, name, amount=...): ...\r
+ def incrby(self, name, amount=...): ...\r
+ def incrbyfloat(self, name, amount=...): ...\r
+ def keys(self, pattern=...): ...\r
+ def mget(self, keys, *args): ...\r
+ def mset(self, *args, **kwargs): ...\r
+ def msetnx(self, *args, **kwargs): ...\r
+ def move(self, name, db): ...\r
+ def persist(self, name): ...\r
+ def pexpire(self, name, time): ...\r
+ def pexpireat(self, name, when): ...\r
+ def psetex(self, name, time_ms, value): ...\r
+ def pttl(self, name): ...\r
+ def randomkey(self): ...\r
+ def rename(self, src, dst): ...\r
+ def renamenx(self, src, dst): ...\r
+ def restore(self, name, ttl, value): ...\r
+ def set(self, name, value, ex=..., px=..., nx=..., xx=...): ...\r
+ def __setitem__(self, name, value): ...\r
+ def setbit(self, name, offset, value): ...\r
+ def setex(self, name, time, value): ...\r
+ def setnx(self, name, value): ...\r
+ def setrange(self, name, offset, value): ...\r
+ def strlen(self, name): ...\r
+ def substr(self, name, start, end=...): ...\r
+ def ttl(self, name): ...\r
+ def type(self, name): ...\r
+ def watch(self, *names): ...\r
+ def unwatch(self): ...\r
+ def blpop(self, keys, timeout=...): ...\r
+ def brpop(self, keys, timeout=...): ...\r
+ def brpoplpush(self, src, dst, timeout=...): ...\r
+ def lindex(self, name, index): ...\r
+ def linsert(self, name, where, refvalue, value): ...\r
+ def llen(self, name): ...\r
+ def lpop(self, name): ...\r
+ def lpush(self, name, *values): ...\r
+ def lpushx(self, name, value): ...\r
+ def lrange(self, name, start, end): ...\r
+ def lrem(self, name, count, value): ...\r
+ def lset(self, name, index, value): ...\r
+ def ltrim(self, name, start, end): ...\r
+ def rpop(self, name): ...\r
+ def rpoplpush(self, src, dst): ...\r
+ def rpush(self, name, *values): ...\r
+ def rpushx(self, name, value): ...\r
+ def sort(self, name, start=..., num=..., by=..., get=..., desc=..., alpha=..., store=..., groups=...): ...\r
+ def scan(self, cursor=..., match=..., count=...): ...\r
+ def scan_iter(self, match=..., count=...): ...\r
+ def sscan(self, name, cursor=..., match=..., count=...): ...\r
+ def sscan_iter(self, name, match=..., count=...): ...\r
+ def hscan(self, name, cursor=..., match=..., count=...): ...\r
+ def hscan_iter(self, name, match=..., count=...): ...\r
+ def zscan(self, name, cursor=..., match=..., count=..., score_cast_func=...): ...\r
+ def zscan_iter(self, name, match=..., count=..., score_cast_func=...): ...\r
+ def sadd(self, name, *values): ...\r
+ def scard(self, name): ...\r
+ def sdiff(self, keys, *args): ...\r
+ def sdiffstore(self, dest, keys, *args): ...\r
+ def sinter(self, keys, *args): ...\r
+ def sinterstore(self, dest, keys, *args): ...\r
+ def sismember(self, name, value): ...\r
+ def smembers(self, name): ...\r
+ def smove(self, src, dst, value): ...\r
+ def spop(self, name): ...\r
+ def srandmember(self, name, number=...): ...\r
+ def srem(self, name, *values): ...\r
+ def sunion(self, keys, *args): ...\r
+ def sunionstore(self, dest, keys, *args): ...\r
+ def zadd(self, name, *args, **kwargs): ...\r
+ def zcard(self, name): ...\r
+ def zcount(self, name, min, max): ...\r
+ def zincrby(self, name, value, amount=...): ...\r
+ def zinterstore(self, dest, keys, aggregate=...): ...\r
+ def zlexcount(self, name, min, max): ...\r
+ def zrange(self, name, start, end, desc=..., withscores=..., score_cast_func=...): ...\r
+ def zrangebylex(self, name, min, max, start=..., num=...): ...\r
+ def zrangebyscore(self, name, min, max, start=..., num=..., withscores=..., score_cast_func=...): ...\r
+ def zrank(self, name, value): ...\r
+ def zrem(self, name, *values): ...\r
+ def zremrangebylex(self, name, min, max): ...\r
+ def zremrangebyrank(self, name, min, max): ...\r
+ def zremrangebyscore(self, name, min, max): ...\r
+ def zrevrange(self, name, start, end, withscores=..., score_cast_func=...): ...\r
+ def zrevrangebyscore(self, name, max, min, start=..., num=..., withscores=..., score_cast_func=...): ...\r
+ def zrevrank(self, name, value): ...\r
+ def zscore(self, name, value): ...\r
+ def zunionstore(self, dest, keys, aggregate=...): ...\r
+ def pfadd(self, name, *values): ...\r
+ def pfcount(self, name): ...\r
+ def pfmerge(self, dest, *sources): ...\r
+ def hdel(self, name, *keys): ...\r
+ def hexists(self, name, key): ...\r
+ def hget(self, name, key): ...\r
+ def hgetall(self, name): ...\r
+ def hincrby(self, name, key, amount=...): ...\r
+ def hincrbyfloat(self, name, key, amount=...): ...\r
+ def hkeys(self, name): ...\r
+ def hlen(self, name): ...\r
+ def hset(self, name, key, value): ...\r
+ def hsetnx(self, name, key, value): ...\r
+ def hmset(self, name, mapping): ...\r
+ def hmget(self, name, keys, *args): ...\r
+ def hvals(self, name): ...\r
+ def publish(self, channel, message): ...\r
+ def eval(self, script, numkeys, *keys_and_args): ...\r
+ def evalsha(self, sha, numkeys, *keys_and_args): ...\r
+ def script_exists(self, *args): ...\r
+ def script_flush(self): ...\r
+ def script_kill(self): ...\r
+ def script_load(self, script): ...\r
+ def register_script(self, script): ...\r
+\r
+class Redis(StrictRedis):\r
+ RESPONSE_CALLBACKS = ... # type: Any\r
+ def pipeline(self, transaction=..., shard_hint=...): ...\r
+ def setex(self, name, value, time): ...\r
+ def lrem(self, name, value, num=...): ...\r
+ def zadd(self, name, *args, **kwargs): ...\r
+\r
+class PubSub:\r
+ PUBLISH_MESSAGE_TYPES = ... # type: Any\r
+ UNSUBSCRIBE_MESSAGE_TYPES = ... # type: Any\r
+ connection_pool = ... # type: Any\r
+ shard_hint = ... # type: Any\r
+ ignore_subscribe_messages = ... # type: Any\r
+ connection = ... # type: Any\r
+ encoding = ... # type: Any\r
+ encoding_errors = ... # type: Any\r
+ decode_responses = ... # type: Any\r
+ def __init__(self, connection_pool, shard_hint=..., ignore_subscribe_messages=...) -> None: ...\r
+ def __del__(self): ...\r
+ channels = ... # type: Any\r
+ patterns = ... # type: Any\r
+ def reset(self): ...\r
+ def close(self): ...\r
+ def on_connect(self, connection): ...\r
+ def encode(self, value): ...\r
+ @property\r
+ def subscribed(self): ...\r
+ def execute_command(self, *args, **kwargs): ...\r
+ def parse_response(self, block=...): ...\r
+ def psubscribe(self, *args, **kwargs): ...\r
+ def punsubscribe(self, *args): ...\r
+ def subscribe(self, *args, **kwargs): ...\r
+ def unsubscribe(self, *args): ...\r
+ def listen(self): ...\r
+ def get_message(self, ignore_subscribe_messages=...): ...\r
+ def handle_message(self, response, ignore_subscribe_messages=...): ...\r
+ def run_in_thread(self, sleep_time=...): ...\r
+\r
+class BasePipeline:\r
+ UNWATCH_COMMANDS = ... # type: Any\r
+ connection_pool = ... # type: Any\r
+ connection = ... # type: Any\r
+ response_callbacks = ... # type: Any\r
+ transaction = ... # type: Any\r
+ shard_hint = ... # type: Any\r
+ watching = ... # type: Any\r
+ def __init__(self, connection_pool, response_callbacks, transaction, shard_hint) -> None: ...\r
+ def __enter__(self): ...\r
+ def __exit__(self, exc_type, exc_value, traceback): ...\r
+ def __del__(self): ...\r
+ def __len__(self): ...\r
+ command_stack = ... # type: Any\r
+ scripts = ... # type: Any\r
+ explicit_transaction = ... # type: Any\r
+ def reset(self): ...\r
+ def multi(self): ...\r
+ def execute_command(self, *args, **kwargs): ...\r
+ def immediate_execute_command(self, *args, **options): ...\r
+ def pipeline_execute_command(self, *args, **options): ...\r
+ def raise_first_error(self, commands, response): ...\r
+ def annotate_exception(self, exception, number, command): ...\r
+ def parse_response(self, connection, command_name, **options): ...\r
+ def load_scripts(self): ...\r
+ def execute(self, raise_on_error=...): ...\r
+ def watch(self, *names): ...\r
+ def unwatch(self): ...\r
+ def script_load_for_pipeline(self, script): ...\r
+\r
+class StrictPipeline(BasePipeline, StrictRedis): ...\r
+class Pipeline(BasePipeline, Redis): ...\r
+\r
+class Script:\r
+ registered_client = ... # type: Any\r
+ script = ... # type: Any\r
+ sha = ... # type: Any\r
+ def __init__(self, registered_client, script) -> None: ...\r
+ def __call__(self, keys=..., args=..., client=...): ...\r
projects / dotfiles / .git / blobdiff