1 from typing import Any
\r
3 ssl_available = ... # type: Any
\r
4 hiredis_version = ... # type: Any
\r
5 HIREDIS_SUPPORTS_CALLABLE_ERRORS = ... # type: Any
\r
6 HIREDIS_SUPPORTS_BYTE_BUFFER = ... # type: Any
\r
7 msg = ... # type: Any
\r
8 HIREDIS_USE_BYTE_BUFFER = ... # type: Any
\r
9 SYM_STAR = ... # type: Any
\r
10 SYM_DOLLAR = ... # type: Any
\r
11 SYM_CRLF = ... # type: Any
\r
12 SYM_EMPTY = ... # type: Any
\r
13 SERVER_CLOSED_CONNECTION_ERROR = ... # type: Any
\r
16 value = ... # type: Any
\r
17 def __init__(self, value) -> None: ...
\r
20 EXCEPTION_CLASSES = ... # type: Any
\r
21 def parse_error(self, response): ...
\r
24 socket_read_size = ... # type: Any
\r
25 bytes_written = ... # type: Any
\r
26 bytes_read = ... # type: Any
\r
27 def __init__(self, socket, socket_read_size) -> None: ...
\r
29 def length(self): ...
\r
30 def read(self, length): ...
\r
31 def readline(self): ...
\r
32 def purge(self): ...
\r
33 def close(self): ...
\r
35 class PythonParser(BaseParser):
\r
36 encoding = ... # type: Any
\r
37 socket_read_size = ... # type: Any
\r
38 def __init__(self, socket_read_size) -> None: ...
\r
39 def __del__(self): ...
\r
40 def on_connect(self, connection): ...
\r
41 def on_disconnect(self): ...
\r
42 def can_read(self): ...
\r
43 def read_response(self): ...
\r
45 class HiredisParser(BaseParser):
\r
46 socket_read_size = ... # type: Any
\r
47 def __init__(self, socket_read_size) -> None: ...
\r
48 def __del__(self): ...
\r
49 def on_connect(self, connection): ...
\r
50 def on_disconnect(self): ...
\r
51 def can_read(self): ...
\r
52 def read_response(self): ...
\r
54 DefaultParser = ... # type: Any
\r
57 description_format = ... # type: Any
\r
58 pid = ... # type: Any
\r
59 host = ... # type: Any
\r
60 port = ... # type: Any
\r
61 db = ... # type: Any
\r
62 password = ... # type: Any
\r
63 socket_timeout = ... # type: Any
\r
64 socket_connect_timeout = ... # type: Any
\r
65 socket_keepalive = ... # type: Any
\r
66 socket_keepalive_options = ... # type: Any
\r
67 retry_on_timeout = ... # type: Any
\r
68 encoding = ... # type: Any
\r
69 encoding_errors = ... # type: Any
\r
70 decode_responses = ... # type: Any
\r
71 def __init__(self, host=..., port=..., db=..., password=..., socket_timeout=..., socket_connect_timeout=..., socket_keepalive=..., socket_keepalive_options=..., retry_on_timeout=..., encoding=..., encoding_errors=..., decode_responses=..., parser_class=..., socket_read_size=...) -> None: ...
\r
72 def __del__(self): ...
\r
73 def register_connect_callback(self, callback): ...
\r
74 def clear_connect_callbacks(self): ...
\r
75 def connect(self): ...
\r
76 def on_connect(self): ...
\r
77 def disconnect(self): ...
\r
78 def send_packed_command(self, command): ...
\r
79 def send_command(self, *args): ...
\r
80 def can_read(self): ...
\r
81 def read_response(self): ...
\r
82 def encode(self, value): ...
\r
83 def pack_command(self, *args): ...
\r
84 def pack_commands(self, commands): ...
\r
86 class SSLConnection(Connection):
\r
87 description_format = ... # type: Any
\r
88 keyfile = ... # type: Any
\r
89 certfile = ... # type: Any
\r
90 cert_reqs = ... # type: Any
\r
91 ca_certs = ... # type: Any
\r
92 def __init__(self, ssl_keyfile=..., ssl_certfile=..., ssl_cert_reqs=..., ssl_ca_certs=..., **kwargs) -> None: ...
\r
94 class UnixDomainSocketConnection(Connection):
\r
95 description_format = ... # type: Any
\r
96 pid = ... # type: Any
\r
97 path = ... # type: Any
\r
98 db = ... # type: Any
\r
99 password = ... # type: Any
\r
100 socket_timeout = ... # type: Any
\r
101 retry_on_timeout = ... # type: Any
\r
102 encoding = ... # type: Any
\r
103 encoding_errors = ... # type: Any
\r
104 decode_responses = ... # type: Any
\r
105 def __init__(self, path=..., db=..., password=..., socket_timeout=..., encoding=..., encoding_errors=..., decode_responses=..., retry_on_timeout=..., parser_class=..., socket_read_size=...) -> None: ...
\r
107 class ConnectionPool:
\r
109 def from_url(cls, url, db=..., **kwargs): ...
\r
110 connection_class = ... # type: Any
\r
111 connection_kwargs = ... # type: Any
\r
112 max_connections = ... # type: Any
\r
113 def __init__(self, connection_class=..., max_connections=..., **connection_kwargs) -> None: ...
\r
114 pid = ... # type: Any
\r
115 def reset(self): ...
\r
116 def get_connection(self, command_name, *keys, **options): ...
\r
117 def make_connection(self): ...
\r
118 def release(self, connection): ...
\r
119 def disconnect(self): ...
\r
121 class BlockingConnectionPool(ConnectionPool):
\r
122 queue_class = ... # type: Any
\r
123 timeout = ... # type: Any
\r
124 def __init__(self, max_connections=..., timeout=..., connection_class=..., queue_class=..., **connection_kwargs) -> None: ...
\r
125 pid = ... # type: Any
\r
126 pool = ... # type: Any
\r
127 def reset(self): ...
\r
128 def make_connection(self): ...
\r
129 def get_connection(self, command_name, *keys, **options): ...
\r
130 def release(self, connection): ...
\r
131 def disconnect(self): ...
\r