| Commit message (Collapse) | Author | Age | Files | Lines |
... | |
|\ \ \
| | | |
| | | | |
adding max_connections option to StrictRedis Class
|
| | | | |
|
| | | |
| | | |
| | | |
| | | | |
-Rename variables for coherence
|
|/ / / |
|
|/ / |
|
| | |
|
|/
|
|
|
| |
ref1: https://github.com/antirez/redis/blob/unstable/src/replication.c#L1783, at SYNCHRONOUS REPLICATION
ref2: http://antirez.com/news/66
This command for Redis-3.0.0 and above now.
|
|\ |
|
| |
| |
| |
| |
| |
| |
| |
| |
| | |
When a watcher error occurs (due to some key being
watched being mutated) the current behavior is to
immediately try again. To avoid the thundering herd
problem a delay is nice to provide to avoid these
situations by introducing a sleep period between these
types of failures.
|
| | |
|
| |
| |
| |
| | |
combination with msgpack and lua
|
|/
|
|
|
| |
properly unsubscribes and cleans up the connection now. also allows
callbacks to call thread.stop() without errors.
|
| |
|
| |
|
|\
| |
| | |
Added bitpos command
|
| | |
|
|/ |
|
|
|
|
| |
fixes #495
|
| |
|
|
|
|
|
| |
* add thread_local=False parameter to Lock.__init__() and StrictRedis.lock()
* use thread_local to decide whether to put token in thread-local storage
|
| |
|
|
|
|
|
| |
* now uses unique string tokens to claim lock ownership
* added extend() method to extend the timeout on an already acquired lock
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Users now have the ability about how socket.timeout errors are handled.
Previously socket.timeout errors were handled just like any other socket error
in that the command would be retried once. This createed a potential race
condition when the client sends a command to a busy Redis server that can't
reply faster than the client's `socket_timeout` option. In this case, the server
will still eventually process the command.
There's now a `retry_on_timeout` option that's set to False by default.
If `retry_on_timeout` is False, any socket.timeout error will raise a
TimeoutError exception. If `retry_on_timeout` is set to True, the client
will retry executing the command once just like other socket.error exceptions.
TODO: Write better tests for this code.
TODO: Much of this logic could/should be moved to the ConnectionPool or
Connection objects.
Fixes #261
|
| |
|
| |
|
| |
|
|\
| |
| |
| |
| |
| | |
Conflicts:
redis/client.py
redis/connection.py
|
| |
| |
| |
| | |
E127 continuation line over-indented for visual indent
|
| | |
|
| | |
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
previously all pieces of a command, including the command name and literal
options to it (such as "WITHSCORES" on ZSET commands) would get encoded.
this works fine on utf-8, but other encodings like utf-16 break.
a new Token class has been introduced that command names and literal options
get wrapped. the encoder falls back to the latin-1 encoding for these
literals as they are all ascii.
fixes #430
|
| |
| |
| |
| |
| |
| |
| | |
StrictRedis.from_url() now creations a connection pool instance and
passes that as the connection_pool argument to the client class.
Cleaned up the test suite for URL parsing and BlockingConnectionPool tests
|
|\ \
| | |
| | |
| | |
| | | |
Conflicts:
tests/test_connection_pool.py
|
| | | |
|
| |/
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
ability to parse UNIX domain socket URLs
* add redis.connection.parse_url()
* moved code from StrictRedis.from_url() to here
* add ability to parse UNIX domain socket URLs
* return keyword args to pass to StrictRedis.__init__()
* StrictRedis.from_url() - call parse_url() to get keyword args
* add classmethod from_url() to ConnectionPool and BlockingConnectionPool
* get keyword args from parse_url()
* touch up keyword args from StrictRedis format for connection pool
* tests/test_connection_pool.py
* add from_url() tests for ConnectionPool and BlockingConnectionPool
* add from_url() tests for a single Redis client object
|
| |
| |
| |
| | |
fixes #474.
|
| |
| |
| |
| | |
http://redis.io/commands/config-rewrite
|
|\ \ |
|
| |\ \
| | | |
| | | | |
Fixed typo in client.py
|
| | |/ |
|
|/ /
| |
| |
| | |
Fixes #424
|
| | |
|
|\ \ |
|
| |/ |
|
|\ \ |
|
| | |
| | |
| | |
| | |
| | | |
The old docstring was incorrect. See http://redis.io/commands/GETSET for
more information.
|
| | | |
|
| | | |
|
| | |
| | |
| | |
| | | |
exception
|