Public Member Functions | |
| def | __del__ |
| def | __init__ |
| def | close |
| def | execute_command |
| def | listen |
| def | parse_response |
| def | psubscribe |
| def | punsubscribe |
| def | reset |
| def | subscribe |
| def | unsubscribe |
Public Attributes | |
| channels | |
| connection | |
| connection_pool | |
| patterns | |
| shard_hint | |
| subscribe_commands | |
| subscription_count | |
PubSub provides publish, subscribe and listen support to Redis channels. After subscribing to one or more channels, the listen() method will block until a message arrives on one of the subscribed channels. That message will be returned and it's safe to start listening again.
| def rocon_python_redis.client.PubSub.__init__ | ( | self, | |
| connection_pool, | |||
shard_hint = None |
|||
| ) |
| def rocon_python_redis.client.PubSub.__del__ | ( | self | ) |
| def rocon_python_redis.client.PubSub.close | ( | self | ) |
| def rocon_python_redis.client.PubSub.execute_command | ( | self, | |
| args, | |||
| kwargs | |||
| ) |
| def rocon_python_redis.client.PubSub.listen | ( | self | ) |
| def rocon_python_redis.client.PubSub.parse_response | ( | self | ) |
| def rocon_python_redis.client.PubSub.psubscribe | ( | self, | |
| patterns | |||
| ) |
| def rocon_python_redis.client.PubSub.punsubscribe | ( | self, | |
patterns = [] |
|||
| ) |
| def rocon_python_redis.client.PubSub.reset | ( | self | ) |
| def rocon_python_redis.client.PubSub.subscribe | ( | self, | |
| channels | |||
| ) |
| def rocon_python_redis.client.PubSub.unsubscribe | ( | self, | |
channels = [] |
|||
| ) |