| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
| |
|
| |
|
|\
| |
| | |
Add support for specifying the token when acquiring a lock
|
| | |
|
| | |
|
| | |
|
| | |
|
|/ |
|
| |
|
| |
|
|\
| |
| | |
Add `.reacquire()` method to Lock
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
`Lock` class provides a method called `.extend()` to manage a TTL of the
acquired lock. However, the method allows only to extend a timeout of
existing lock by N seconds, there's no way you can reset a TTL to the
timeout value you passed to this lock. There could be multiple use cases
for such behaviour. For instance, one may want to use a lock to
implement active/passive behaviour where only one process owns a lock
and resets its TTL all over again until it dies. This commit adds a new
method called `.reacquire()` to reset a TTL of the acquired lock back to
the passed timeout value.
|
|\ \
| |/
|/| |
Remove unnecessary compat shim for 'bytes'
|
|/
|
|
|
|
| |
Both Python 2.7 & Python 3 have the types bytes. On Python 2.7, it is an
alias for the type str, same as what was previously defined in
_compat.py.
|
|
|
|
| |
Stream message now respect the decode_responses flag.
|
| |
|
| |
|
| |
|
|
|
|
|
|
|
| |
Redis 5.0.1 and beyond require that COUNT be specified as a positive
integer. Since we can't guess the maximum possible value (UULONG_MAX
can vary based on server architecture), force min/max/count to be
required arguments
|
|
|
|
|
|
|
| |
Redis versions 5.0.1 require messages to be read with the special ID '>'
when using XREADGROUP
Fixes #1073
|
|
|
|
|
|
|
| |
When incr=True and xx=True and an element is specified that doesn't exist
the Redis server returns None. redis-py now does this as well.
Fixes #1084
|
|\
| |
| | |
Remove outdated distutils fallback
|
|/
|
|
|
| |
Modern Python environments have setuptools or pip installed. The
distutils fallback is unnecessary.
|
|\
| |
| | |
Re-fix the recently broken INFO parsing, see #1018
|
| |
| |
| |
| |
| | |
The value part of the info line may contains : in many cases,
most importantly an IPv6 slave address, may cause the parser to crash.
|
| | |
|
|\ \
| | |
| | | |
Add client kill with filter
|
| | | |
|
| | | |
|
| | |
| | |
| | |
| | | |
changed skipme to a bool
use a list to accumulate filter options
|
| | |
| | |
| | |
| | | |
Signed-off-by: Theo Despoudis <thdespou@hotmail.com>
|
| | |
| | |
| | |
| | | |
Signed-off-by: Theo Despoudis <thdespou@hotmail.com>
|
| | |
| | |
| | |
| | | |
Signed-off-by: Theo Despoudis <thdespou@hotmail.com>
|
| | |
| | |
| | |
| | | |
Signed-off-by: Theo Despoudis <thdespou@hotmail.com>
|
| | |
| | |
| | |
| | | |
Signed-off-by: Theo Despoudis <thdespou@hotmail.com>
|
| | |
| | |
| | |
| | | |
Signed-off-by: Theo Despoudis <thdespou@hotmail.com>
|
|\ \ \
| | | |
| | | | |
Fix #764 - sub-unsub-resub caused PubSub() to forget the channel
|
| | | | |
|
|/ / / |
|
|\ \ \
| | | |
| | | | |
Use tox "extras" option to install package extras
|
|/ / /
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
For details, see:
https://tox.readthedocs.io/en/latest/config.html#conf-extras
Removes the need to duplicate the version string in tox.ini. Allow
setup.py to be the single source of truth.
|
|\ \ \
| | | |
| | | | |
Use 'dist: xenial' in Travis to simplify configuration
|
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | | |
Allows using Python version 3.7 without sudo declarations.
Travis officially added support for Xenial on 2018-11-08.
https://blog.travis-ci.com/2018-11-08-xenial-release
Add Python 3.7 to tox.ini and setup.py as well.
|
|\ \ \ \
| |_|/ /
|/| | | |
Add github templates.
|
|/ / /
| | |
| | |
| | |
| | |
| | |
| | | |
ISSUE_TEMPLATE for creating issues
PULL_REQUEST_TEMPLATE for creating PRs
Signed-off-by: Theo Despoudis <thdespou@hotmail.com>
|
| | | |
|
|\ \ \
| | | |
| | | | |
Extend lock error for not owned special case
|
|/ / /
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
Using the locking routines, it is useful to be able to
distingush a generic lock error from a one that is related
to the lock not being owned anymore (without doing string
checks); this allows say a lock extension thread to attempt
to re-acquire the lock in this case (vs just dying).
|
| | | |
|