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