summaryrefslogtreecommitdiff
path: root/redis/commands/cluster.py
Commit message (Collapse)AuthorAgeFilesLines
* Add support for cluster myshardid (#2704)Anurag Bandyopadhyay2023-05-081-1/+8
| | | | | | | | | | | | | | | | | | | * 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>
* Allow EVAL_RO and EVALSHA_RO to be routed to read replica (#2494)Dongkeun Lee2022-12-251-0/+2
| | | | | | | | | | | | * 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>
* Raising NotImplementedError for certain CLUSTER commands (#2504)dvora-h2022-12-141-0/+10
| | | Co-authored-by: Chayim <chayim@users.noreply.github.com>
* Fix KeyError in async cluster - initialize before execute multi key commands ↵dvora-h2022-10-301-0/+19
| | | | | | | | | (#2439) * Fix KeyError in async cluster * link to issue * typo
* Replace `ensure_future` with `create_task` (#2311)dvora-h2022-08-021-1/+1
| | | | | * Replace `ensure_future` with `create_task` * linters
* commands/cluster: use pipeline to execute split commands (#2230)Utkarsh Gupta2022-06-271-90/+114
| | | | | | - 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 (#2151)dvora-h2022-05-081-0/+8
| | | | | | | | | * Add support for CLUSTER SHARDS * linters * add docstring * linters
* Add Async RedisCluster (#2099)Utkarsh Gupta2022-05-081-159/+408
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | * 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>
* Minor cleanups in commands/cluster.py (#2094)Binbin2022-04-281-4/+3
|
* Cluster commands linkdocs (#2069)Binbin2022-04-041-5/+90
| | | | | | | | | | | | | | * 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>
* Add support for CLUSTER MYID (#2063)Binbin2022-03-311-0/+11
| | | Co-authored-by: enjoy-binbin <binbin.zhu@tenclass.com>
* [CLUSTER] Fix scan command cursors & Fix scan_iter (#2054)Utkarsh Gupta2022-03-231-0/+38
| | | | | | | * 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>
* Add support for CLUSTER LINKS (#2019)dvora-h2022-03-141-0/+12
| | | | | | | | | * cluster links * docstring * skip test Co-authored-by: Chayim <chayim@users.noreply.github.com>
* Add support for CLUSTER DELSLOTSRANGE (#2018)dvora-h2022-03-141-0/+11
| | | | | | | | | | | * delslotsrange * test * linters * skip test * linters
* Add support for CLUSTER ADDSLOTSRANGE (#2017)dvora-h2022-03-141-0/+16
| | | | | | | | | | | | | * add cluster addslotsrange * Add support for CLUSTER ADDSLOTSRANGE * docstring * fix test * skip test * linters
* Add cluster support for functions (#2016)dvora-h2022-03-061-0/+2
| | | | | | | | | | | | | | | | | | | * cluster support for functions * fix test_list_on_cluster mark * fix mark * cluster unstable url * fix * fix cluster url * skip tests * linters * linters
* Add support for JSON, TIMESERIES, BLOOM & GRAPH commands in cluster (#2032)dvora-h2022-03-061-0/+2
| | | Co-authored-by: Chayim <chayim@users.noreply.github.com>
* Add cluster support for scripting (#1937)Jake Barnwell2022-02-221-1/+8
| | | | | | | | | | | * 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>
* Migrated targeted nodes to kwargs in Cluster Mode (#1762)Bar Shaul2021-12-011-553/+45
|
* Added black and isort (#1734)Anas2021-11-301-204/+202
|
* Pyupgrade + flynt + f-strings (#1759)Aarni Koskela2021-11-301-12/+8
| | | @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.
* Adding RedisCluster client to support Redis Cluster Mode (#1660)Bar Shaul2021-11-251-0/+926
Co-authored-by: Chayim <chayim@users.noreply.github.com> Co-authored-by: Anas <anas.el.amraoui@live.com>