| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* feat: adding support for cluster myshardid
* lint fix
* fix: comment fix and async test
* fix: adding version check
* fix lint:
* linters
---------
Co-authored-by: Anuragkillswitch <70265851+Anuragkillswitch@users.noreply.github.com>
Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
Co-authored-by: dvora-h <dvora.heller@redis.com>
|
|
|
|
|
|
|
|
|
|
|
|
| |
* fix typo (Lue -> Lua)
* run eval_ro, evalsha_ro test on redis cluster
* Add eval_ro, evalsha_ro to read only commands
* assert that commands are run in a round robin manner
Co-authored-by: zach.lee <zach.lee@sendbird.com>
Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
|
|
|
| |
Co-authored-by: Chayim <chayim@users.noreply.github.com>
|
|
|
|
|
|
|
|
|
| |
(#2439)
* Fix KeyError in async cluster
* link to issue
* typo
|
|
|
|
|
| |
* Replace `ensure_future` with `create_task`
* linters
|
|
|
|
|
|
| |
- allow passing target_nodes to pipeline commands
- move READ_COMMANDS to commands/cluster to avoid import cycle
- add types to list_or_args
|
|
|
|
|
|
|
|
|
| |
* Add support for CLUSTER SHARDS
* linters
* add docstring
* linters
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* Copy Cluster Client, Commands, Commands Parser, Tests for asyncio
* Async Cluster Tests: Async/Await
* Add Async RedisCluster
* cluster: use ERRORS_ALLOW_RETRY from self.__class__
* async_cluster: rework redis_connection, initialize, & close
- move redis_connection from NodesManager to ClusterNode & handle all related logic in ClusterNode class
- use Locks while initializing or closing
- in case of error, close connections instead of instantly reinitializing
- create ResourceWarning instead of manually deleting client object
- use asyncio.gather to run commands/initialize/close in parallel
- inline single use functions
- fix test_acl_log for py3.6
* async_cluster: add types
* async_cluster: add docs
* docs: update sphinx & add sphinx_autodoc_typehints
* async_cluster: move TargetNodesT to cluster module
* async_cluster/commands: inherit commands from sync class if possible
* async_cluster: add benchmark script with aredis & aioredis-cluster
* async_cluster: remove logging
* async_cluster: inline functions
* async_cluster: manage Connection instead of Redis Client
* async_cluster/commands: optimize parser
* async_cluster: use ensure_future & generators for gather
* async_conn: optimize
* async_cluster: optimize determine_slot
* async_cluster: optimize determine_nodes
* async_cluster/parser: optimize _get_moveable_keys
* async_cluster: inlined check_slots_coverage
* async_cluster: update docstrings
* async_cluster: add concurrent test & use read_response/_update_moved_slots without lock
Co-authored-by: Chayim <chayim@users.noreply.github.com>
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* Link documentation for all cluster commands
Added links to the documentation in the docstrings in redis/commands/cluster.py
Part of #1712
* copy stralgo comment from commands/core.py to commands/cluster.py
* fix linters
Co-authored-by: enjoy-binbin <binbin.zhu@tenclass.com>
Co-authored-by: Chayim I. Kirshen <c@kirshen.com>
Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
|
|
|
| |
Co-authored-by: enjoy-binbin <binbin.zhu@tenclass.com>
|
|
|
|
|
|
|
| |
* cluster/scan: fix return cursor & change default node to primaries
* cluster/scan_iter: fix iteration
Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
|
|
|
|
|
|
|
|
|
| |
* cluster links
* docstring
* skip test
Co-authored-by: Chayim <chayim@users.noreply.github.com>
|
|
|
|
|
|
|
|
|
|
|
| |
* delslotsrange
* test
* linters
* skip test
* linters
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* add cluster addslotsrange
* Add support for CLUSTER ADDSLOTSRANGE
* docstring
* fix test
* skip test
* linters
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* cluster support for functions
* fix test_list_on_cluster mark
* fix mark
* cluster unstable url
* fix
* fix cluster url
* skip tests
* linters
* linters
|
|
|
| |
Co-authored-by: Chayim <chayim@users.noreply.github.com>
|
|
|
|
|
|
|
|
|
|
|
| |
* Add cluster support for scripting
* Fall back to connection_pool.get_encoder if necessary
* Add documentation for cluster-based scripting
* Add test for flush response
Co-authored-by: dvora-h <dvora.heller@redis.com>
|
| |
|
| |
|
|
|
| |
@akx Thank you so much for this! Thanks again for introducing me to a new tool that I'm sliding into my workflow as well.
|
|
Co-authored-by: Chayim <chayim@users.noreply.github.com>
Co-authored-by: Anas <anas.el.amraoui@live.com>
|