Bases: BaseCommand
Mixin for Redis Connection commands (e.g. PING, ECHO).
Source code in pyredis/commands/connection.py
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28 | class Connection(BaseCommand):
"""Mixin for Redis Connection commands (e.g. PING, ECHO)."""
def __init__(self):
super().__init__()
def echo(self, *args, shard_key=None, sock=None):
if self._cluster:
return self.execute(
*[b"ECHO", *args],
shard_key=shard_key,
sock=sock
)
return self.execute(
*[b"ECHO", *args]
)
def ping(self, shard_key=None, sock=None):
if self._cluster:
return self.execute(
b"PING",
shard_key=shard_key,
sock=sock
)
return self.execute(b"PING")
|
__init__()
Source code in pyredis/commands/connection.py
| def __init__(self):
super().__init__()
|
echo(*args, shard_key=None, sock=None)
Source code in pyredis/commands/connection.py
10
11
12
13
14
15
16
17
18
19 | def echo(self, *args, shard_key=None, sock=None):
if self._cluster:
return self.execute(
*[b"ECHO", *args],
shard_key=shard_key,
sock=sock
)
return self.execute(
*[b"ECHO", *args]
)
|
execute(*args, **kwargs)
Source code in pyredis/commands/base.py
| def execute(self, *args, **kwargs):
raise NotImplementedError
|
ping(shard_key=None, sock=None)
Source code in pyredis/commands/connection.py
| def ping(self, shard_key=None, sock=None):
if self._cluster:
return self.execute(
b"PING",
shard_key=shard_key,
sock=sock
)
return self.execute(b"PING")
|