Ë
|
|
çúhz ã óÒ d dl Z d dlmZmZmZmZmZmZmZm Z m
|
Z
|
m Z m Z m Z d dlmZ d dlmZmZ d dlmZmZmZmZmZmZmZ ddlm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z( ddl)m*Z* dd l+m,Z,m-Z- erd d
|
l.m/Z/ e0g d ¢« Z1 G d d e« Z2 G d de2« Z3 G d de%« Z4 G d de4e « Z5 G d de#« Z6 G d de6e « Z7 G d de2e4e e'e6e(e$e&e-« Z8 G d de3e5e e7e"e e!e,«
|
Z9y) é N) Ú TYPE_CHECKINGÚAnyÚ AsyncIteratorÚDictÚIterableÚIteratorÚListÚLiteralÚMappingÚNoReturnÚOptionalÚUnion)Úkey_slot)ÚRedisClusterExceptionÚ
|
RedisError)ÚAnyKeyTÚClusterCommandsProtocolÚ
|
EncodableTÚKeysTÚKeyTÚPatternTÚ ResponseTé ) Ú ACLCommandsÚAsyncACLCommandsÚAsyncDataAccessCommandsÚAsyncFunctionCommandsÚAsyncManagementCommandsÚAsyncModuleCommandsÚAsyncScriptCommandsÚDataAccessCommandsÚFunctionCommandsÚManagementCommandsÚModuleCommandsÚPubSubCommandsÚScriptCommands)Ú list_or_args)ÚAsyncRedisModuleCommandsÚRedisModuleCommands)Ú TargetNodesT))ÚBITCOUNTÚBITPOSÚEVAL_ROÚ
|
EVALSHA_ROÚEXISTSÚGEODISTÚGEOHASHÚGEOPOSÚ GEORADIUSÚGEORADIUSBYMEMBERÚGETÚGETBITÚGETRANGEÚHEXISTSÚHGETÚHGETALLÚHKEYSÚHLENÚHMGETÚHSTRLENÚHVALSÚKEYSÚLINDEXÚLLENÚLRANGEÚMGETÚPTTLÚ RANDOMKEYÚSCARDÚSDIFFÚSINTERÚ SISMEMBERÚSMEMBERSÚ SRANDMEMBERÚSTRLENÚSUNIONÚTTLÚZCARDÚZCOUNTÚZRANGEÚZSCOREc óX e Zd ZdZdee deeee f fdZ de
|
e e f deeee f fdZ dede
|
eee f dee fd Zdee de
|
eee f d
|
ee dee fd Zded edeee fd Zde
|
e e f dee fdZdededefdZdedefdZdedefdZdedefdZdedefdZ y)ÚClusterMultiKeyCommandsúC
|
A class containing commands that handle more than one key
|
ÚkeysÚreturnc ó¢ i }|D ]G }t | j j |« « }|j |g « j |« I |S )z@Split keys into a dictionary that maps a slot to a list of keys.)r ÚencoderÚencodeÚ
|
setdefaultÚappend)ÚselfrW Ú slots_to_keysÚkeyÚslots õi H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/commands/cluster.pyÚ_partition_keys_by_slotz/ClusterMultiKeyCommands._partition_keys_by_sloth sT ð Øò ;CÜDLL× /Ñ /°Ó 4Ó5DØ × $Ñ $ T¨2Ó .× 5Ñ 5°cÕ :ð ;ð Ð ó Úmappingc óÄ i }|j « D ]J }t | j j |d « « }|j |g « j |« L |S )zBSplit pairs into a dictionary that maps a slot to a list of pairs.r )Úitemsr rZ r[ r\ Úextend)r^ re Úslots_to_pairsÚpairra s rb Ú_partition_pairs_by_slotz0ClusterMultiKeyCommands._partition_pairs_by_slotr s^ ð
|
ØMMOò =DÜDLL× /Ñ /°°Q±Ó 8Ó9DØ × %Ñ % d¨BÓ /× 6Ñ 6°tÕ <ð =ð Ð rd ÚcommandÚ slots_to_argsc ó | j xr |t v }| j « }|j « D cg c]6 \ }} |j |g|¢d| j
|
j ||« gi8 c}} |j « S c c}}w ©NÚ target_nodes)Úread_from_replicasÚ READ_COMMANDSÚpipelinerg Úexecute_commandÚ nodes_managerÚget_node_from_slotÚexecute©r^ rl rm rq Úpipera Ú slot_argss rb Ú_execute_pipeline_by_slotz1ClusterMultiKeyCommands._execute_pipeline_by_slot~ s ð "× 4Ñ 4Ò Q¸ÄMÐ9QÐØ}}ð $1×#6Ñ#6Ó#8÷
|
ñ ið !D× Ñ Øð àò ð ×&Ñ&×9Ñ9¸$Ð@RÓSð ó ô
|
ð ||~Ð ùó
|
s º;B Ú responsesc
|
óÌ t |j « |« D ci c] \ }}t ||« D ] \ }}||
|
}}}}}|D cg c] } || c} S c c}}}}w c c} w ©N)ÚzipÚvalues)
|
r^ rW rm r| Ú slot_valuesÚresponseÚkÚvÚresultsr` s
|
rb Ú_reorder_keys_by_commandz0ClusterMultiKeyCommands._reorder_keys_by_command s ô *-¨]×-AÑ-AÓ-CÀYÓ)O÷
|
ñ
|
á% XÜK¨Ó2ò
|
ñ 1ð qDð
|
Ø ð
|
ó
|
ð
|
)-Ö- Ò-Ð-ùõ
|
ùò
|
.s !A
|
Á
|
A!Úargsc ó t ||« }| j |« }| j d|« }| j |||« S )áA
|
Splits the keys into different slots and then calls MGET
|
for the keys of every slot. This operation will not be atomic
|
if keys belong to more than one slot.
|
|
Returns a list of values ordered identically to ``keys``
|
|
For more information see https://redis.io/commands/mget
|
rD ©r' rc r{ r ©r^ rW r r_ Úress rb Úmget_nonatomicz&ClusterMultiKeyCommands.mget_nonatomic sM ô D $Ó'ð ×4Ñ4°TÓ: ð ×,Ñ,¨V°]ÓCð ×,Ñ,¨T°=À#ÓFÐFrd c óH | j |« }| j d|« S )áÀ
|
Sets key/values based on a mapping. Mapping is a dictionary of
|
key/value pairs. Both keys and values should be strings or types that
|
can be cast to a string via str().
|
|
Splits the keys into different slots and then calls MSET
|
for the keys of every slot. This operation will not be atomic
|
if keys belong to more than one slot.
|
|
For more information see https://redis.io/commands/mset
|
ÚMSET©rk r{ ©r^ re ri s rb Úmset_nonatomicz&ClusterMultiKeyCommands.mset_nonatomic³ s) ð ×6Ñ6°wÓ?ð ×-Ñ-¨f°nÓEÐErd c óZ | j |« }t | j ||« « S )úv
|
Runs the given command once for the keys
|
of each slot. Returns the sum of the return values.
|
©rc Úsumr{ ©r^ rl rW r_ s rb Ú_split_command_across_slotsz3ClusterMultiKeyCommands._split_command_across_slotsÆ s. ð ×4Ñ4°TÓ: ô 4×1Ñ1°'¸=ÓIÓJÐJrd c ó( | j dg|¢ S )zþ
|
Returns the number of ``names`` that exist in the
|
whole cluster. The keys are first split up into slots
|
and then an EXISTS command is sent for every slot
|
|
For more information see https://redis.io/commands/exists
|
r/ ©r ©r^ rW s rb Úexistsz ClusterMultiKeyCommands.existsÒ s ð 0t×/Ñ/°Ð@¸4Ò@Ð@rd c ó( | j dg|¢ S )a<
|
Deletes the given keys in the cluster.
|
The keys are first split up into slots
|
and then an DEL command is sent for every slot
|
|
Non-existent keys are ignored.
|
Returns the number of keys that were deleted.
|
|
For more information see https://redis.io/commands/del
|
ÚDELr r s rb Údeletez ClusterMultiKeyCommands.deleteÜ s ð 0t×/Ñ/°Ð=¸Ò=Ð=rd c ó( | j dg|¢ S )aa
|
Updates the last access time of given keys across the
|
cluster.
|
|
The keys are first split up into slots
|
and then an TOUCH command is sent for every slot
|
|
Non-existent keys are ignored.
|
Returns the number of keys that were touched.
|
|
For more information see https://redis.io/commands/touch
|
ÚTOUCHr r s rb Útouchz ClusterMultiKeyCommands.touché s ð 0t×/Ñ/°Ð?¸$Ò?Ð?rd c ó( | j dg|¢ S )aM
|
Remove the specified keys in a different thread.
|
|
The keys are first split up into slots
|
and then an TOUCH command is sent for every slot
|
|
Non-existent keys are ignored.
|
Returns the number of keys that were unlinked.
|
|
For more information see https://redis.io/commands/unlink
|
ÚUNLINKr r s rb Úunlinkz ClusterMultiKeyCommands.unlinkø s ð 0t×/Ñ/°Ð@¸4Ò@Ð@rd N) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r r Úintr rc r r r rk Ústrr r{ r r r r Úboolr r r r r r£ r¦ © rd rb rU rU c s ñð ¨H°T©Nð ¸tÀCÈÈdÉÀOÑ?Tó ð
|
Ø w¨
|
Ð 2Ñ3ð
|
à c4
|
Ñ#Ð#Ñ $ó
|
ð Øð Ø+2°3¸ÀÑ8LÐ3LÑ+Mð à có ð" .àtnð .ð s H¨ZÑ$8Ð 8Ñ9ð .ð C=ð .ð
|
|
có .ðG 5ð G°ð G¸$¸xȹ}Ñ:Mó Gð.F g¨g°zÐ.AÑ&Bð FÀtÈDÁzó Fð&
|
K°3ð
|
K¸tð
|
KÈó
|
KðADð A Yó Að >Dð > Yó >ð @4ð @ Ió @ð ADð A Yô Ard rU c ó e Zd ZdZdededeee fdZ de
|
e e f dee fdZdededefd Zded
|
e
|
eee f dee fd Zy ) Ú AsyncClusterMultiKeyCommandsrV rW r rX c ó¢ K t ||« }| j |« }| j d|« d{ }| j |||« S 7 w)r rD Nr r s rb r z+AsyncClusterMultiKeyCommands.mget_nonatomic sZ è ø ô D $Ó'ð ×4Ñ4°TÓ: ð ×2Ñ2°6¸=ÓI×Ið ×,Ñ,¨T°=À#ÓFÐFð Jús 3AµA ¶Are c ód K | j |« }| j d|« d{ S 7 w)r r Nr r s rb r z+AsyncClusterMultiKeyCommands.mset_nonatomic# s3 è ø ð ×6Ñ6°wÓ?ð ×3Ñ3°F¸NÓK×KÐKÐKús '0©.ª0rl c óv K | j |« }t | j ||« d{ « S 7 w)r Nr r s rb r z8AsyncClusterMultiKeyCommands._split_command_across_slots6 s8 è ø ð ×4Ñ4°TÓ: ô ×7Ñ7¸À ÓO×OÓPÐPÐOús ,9®7¯ 9rm c ó K | j r| j « d { | j xr |t v }| j « }|j « D cg c]6 \ }} |j |g|¢d| j j ||« gi8 c}} |j « d { S 7 c c}}w 7 wro )
|
Ú _initializeÚ
|
initializerq rr rs rg rt ru rv rw rx s rb r{ z6AsyncClusterMultiKeyCommands._execute_pipeline_by_slotB sÄ è ø ð × Ò Ø//Ó#× #Ð #Ø !× 4Ñ 4Ò Q¸ÄMÐ9QÐØ}}ð $1×#6Ñ#6Ó#8÷
|
ñ ið !D× Ñ Øð àò ð ×&Ñ&×9Ñ9¸$Ð@RÓSð ó ô
|
ð \\^×#Ð#ð $úó
|
ð $ús- C¢B7£=CÁ ;B9ÂCÂ2B?Â3CÂ9CN)r§ r¨ r© rª r r r r r r r r r r r r¬ r« r r r{ r® rd rb r° r° s¡ ñðG¨ð G°tð GÀÀXÈcÁ]Ñ@Só Gð.L¨G°G¸ZÐ4GÑ,Hð LÈTÐRVÉZó Lð&
|
Q¸ð
|
QÀTð
|
QÈcó
|
Qð$Øð$Ø+2°3¸ÀÑ8LÐ3LÑ+Mð$à cô$rd r° c
|
ó e Zd ZdZdefdZdefdZdefdZdddefdZ ddd e
|
defd
|
Z ddd e
|
defd Z d e defd ZdedefdZd e
|
dee fdZd e
|
defdZ d2dddee defdZd2ded defdZdedefdZ d2dede ded defdZdefd Zdddedefd Z d3d eded defd Z d2ded defd Z d!e d"e defd#Z d2d$e ded defd%Z ddded e d&edef
|
d'Z d e defd(Z! d2deded defd)Z"d2ded defd*Z#d2d+Z$d2d,Z%dddefd-Z&d2ded ddfd.Z'd2ded ddfd/Z(d2ded defd0Z)d2ded defd1Z*y)4ÚClusterManagementCommandsú¸
|
A class for Redis Cluster management commands
|
|
The class inherits from Redis's core ManagementCommands class and do the
|
required adjustments to work with cluster mode
|
rX c ó t d« )z
|
Make the server a replica of another instance, or promote it as master.
|
|
For more information see https://redis.io/commands/slaveof
|
z(SLAVEOF is not supported in cluster mode©r ©r^ r Úkwargss rb Úslaveofz!ClusterManagementCommands.slaveof^ s ô $Ð$NÓOÐOrd c ó t d« )z
|
Make the server a replica of another instance, or promote it as master.
|
|
For more information see https://redis.io/commands/replicaof
|
z*REPLICAOF is not supported in cluster moder» r¼ s rb Ú replicaofz#ClusterManagementCommands.replicaoff s ô $Ð$PÓQÐQrd c ó t d« )zo
|
Swaps two Redis databases.
|
|
For more information see https://redis.io/commands/swapdb
|
z'SWAPDB is not supported in cluster moder» r¼ s rb Úswapdbz ClusterManagementCommands.swapdbn s ô $Ð$MÓNÐNrd Ú target_noder* c ó( | j d|¬« S )zÈ
|
Returns the node's id.
|
|
:target_node: 'ClusterNode'
|
The node to execute the command on
|
|
For more information check https://redis.io/commands/cluster-myid/
|
z CLUSTER MYID©rp ©rt ©r^ rà s rb Ú cluster_myidz&ClusterManagementCommands.cluster_myidv s ð ×#Ñ# NÀÐ#ÓMÐMrd Úslotsc ó. | j dg|¢d|iS )zô
|
Assign new hash slots to receiving node. Sends to specified node.
|
|
:target_node: 'ClusterNode'
|
The node to execute the command on
|
|
For more information see https://redis.io/commands/cluster-addslots
|
zCLUSTER ADDSLOTSrp rÆ ©r^ rà rÉ s rb Úcluster_addslotsz*ClusterManagementCommands.cluster_addslots s, ð $t×#Ñ#Ø ð
|
Ø!&ò
|
Ø5@ñ
|
ð
|
rd c ó. | j dg|¢d|iS )aÈ
|
Similar to the CLUSTER ADDSLOTS command.
|
The difference between the two commands is that ADDSLOTS takes a list of slots
|
to assign to the node, while ADDSLOTSRANGE takes a list of slot ranges
|
(specified by start and end slots) to assign to the node.
|
|
:target_node: 'ClusterNode'
|
The node to execute the command on
|
|
For more information see https://redis.io/commands/cluster-addslotsrange
|
zCLUSTER ADDSLOTSRANGErp rÆ rË s rb Úcluster_addslotsrangez/ClusterManagementCommands.cluster_addslotsrange s, ð $t×#Ñ#Ø #ð
|
Ø&+ò
|
Ø:Eñ
|
ð
|
rd Úslot_idc ó& | j d|« S )zÐ
|
Return the number of local keys in the specified hash slot
|
Send to node based on specified slot_id
|
|
For more information see https://redis.io/commands/cluster-countkeysinslot
|
zCLUSTER COUNTKEYSINSLOTrÆ ©r^ rÏ s rb Úcluster_countkeysinslotz1ClusterManagementCommands.cluster_countkeysinslot¢ s ð ×#Ñ#Ð$=¸wÓGÐGrd Únode_idc ó& | j d|« S )zÇ
|
Return the number of failure reports active for a given node
|
Sends to a random node
|
|
For more information see https://redis.io/commands/cluster-count-failure-reports
|
z CLUSTER COUNT-FAILURE-REPORTSrÆ )r^ rÓ s rb Ú cluster_count_failure_reportz6ClusterManagementCommands.cluster_count_failure_report« s ð ×#Ñ#Ð$CÀWÓMÐMrd c óL |D cg c] }| j d|« c}S c c}w )á
|
Set hash slots as unbound in the cluster.
|
It determines by it self what node the slot is in and sends it there
|
|
Returns a list of the results for each processed slot.
|
|
For more information see https://redis.io/commands/cluster-delslots
|
úCLUSTER DELSLOTSrÆ )r^ rÉ ra s rb Úcluster_delslotsz*ClusterManagementCommands.cluster_delslots´ s( ð LQÖQÀ4×$Ñ$Ð%7¸Õ>ÒQÐQùÒQs
!c ó( | j dg|¢ S )aQ
|
Similar to the CLUSTER DELSLOTS command.
|
The difference is that CLUSTER DELSLOTS takes a list of hash slots to remove
|
from the node, while CLUSTER DELSLOTSRANGE takes a list of slot ranges to remove
|
from the node.
|
|
For more information see https://redis.io/commands/cluster-delslotsrange
|
zCLUSTER DELSLOTSRANGErÆ ©r^ rÉ s rb Úcluster_delslotsrangez/ClusterManagementCommands.cluster_delslotsrange¿ s ð $t×#Ñ#Ð$;ÐD¸eÒDÐDrd NÚoptionc ó |r4|j « dvrt d| « | j d||¬« S | j d|¬« S )a
|
Forces a slave to perform a manual failover of its master
|
Sends to specified node
|
|
:target_node: 'ClusterNode'
|
The node to execute the command on
|
|
For more information see https://redis.io/commands/cluster-failover
|
)ÚFORCEÚTAKEOVERz-Invalid option for CLUSTER FAILOVER command: zCLUSTER FAILOVERrÅ )Úupperr rt )r^ rà rÝ s rb Úcluster_failoverz*ClusterManagementCommands.cluster_failoverÊ sg ñ Ø||~Ð%:Ñ:Ü ØCÀFÀ8ÐLóð ð ×+Ñ+Ø&¨¸[ð ,ó ð ð ×'Ñ'Ð(:ÈÐ'ÓUÐ Urd rp c ó( | j d|¬« S )zñ
|
Provides info about Redis Cluster node state.
|
The command will be sent to a random node in the cluster if no target
|
node is specified.
|
|
For more information see https://redis.io/commands/cluster-info
|
z CLUSTER INFOrÅ rÆ ©r^ rp s rb Ú cluster_infoz&ClusterManagementCommands.cluster_infoâ s ð ×#Ñ# NÀ Ð#ÓNÐNrd r` c ó& | j d|« S )z´
|
Returns the hash slot of the specified key
|
Sends to random node in the cluster
|
|
For more information see https://redis.io/commands/cluster-keyslot
|
zCLUSTER KEYSLOTrÆ )r^ r` s rb Úcluster_keyslotz)ClusterManagementCommands.cluster_keyslotì s ð ×#Ñ#Ð$5°sÓ;Ð;rd ÚhostÚportc ó, | j d|||¬« S )z°
|
Force a node cluster to handshake with another node.
|
Sends to specified node.
|
|
For more information see https://redis.io/commands/cluster-meet
|
z CLUSTER MEETrÅ rÆ )r^ rè ré rp s rb Ú cluster_meetz&ClusterManagementCommands.cluster_meetõ s% ð ×#Ñ#Ø D $°\ð $ó
|
ð
|
rd c ó$ | j d« S )z¨
|
Get Cluster config for the node.
|
Sends to random node in the cluster
|
|
For more information see https://redis.io/commands/cluster-nodes
|
z CLUSTER NODESrÆ )r^ s rb Ú cluster_nodesz'ClusterManagementCommands.cluster_nodes s ð ×#Ñ# OÓ4Ð4rd c ó* | j d||¬« S )z
|
Reconfigure a node as a slave of the specified master node
|
|
For more information see https://redis.io/commands/cluster-replicate
|
zCLUSTER REPLICATErÅ rÆ )r^ rp rÓ s rb Úcluster_replicatez+ClusterManagementCommands.cluster_replicate s# ð ×#Ñ#Ø °|ð $ó
|
ð
|
rd Úsoftc ó> | j d|rd|¬« S d|¬« S )zð
|
Reset a Redis Cluster node
|
|
If 'soft' is True then it will send 'SOFT' argument
|
If 'soft' is False then it will send 'HARD' argument
|
|
For more information see https://redis.io/commands/cluster-reset
|
z CLUSTER RESETs SOFTs HARDrÅ rÆ )r^ rð rp s rb Ú cluster_resetz'ClusterManagementCommands.cluster_reset s9 ð ×#Ñ#Ø ©WÈ ð $ó
|
ð
|
Ø29È ð $ó
|
ð
|
rd c ó( | j d|¬« S )z
|
Forces the node to save cluster state on disk
|
|
For more information see https://redis.io/commands/cluster-saveconfig
|
zCLUSTER SAVECONFIGrÅ rÆ rä s rb Úcluster_save_configz-ClusterManagementCommands.cluster_save_config& s ð ×#Ñ#Ð$8À|Ð#ÓTÐTrd ra Únum_keysc ó( | j d||« S )z
|
Returns the number of keys in the specified cluster slot
|
|
For more information see https://redis.io/commands/cluster-getkeysinslot
|
zCLUSTER GETKEYSINSLOTrÆ )r^ ra rõ s rb Úcluster_get_keys_in_slotz2ClusterManagementCommands.cluster_get_keys_in_slot0 s ð ×#Ñ#Ð$;¸TÀ8ÓLÐLrd Úepochc ó* | j d||¬« S )z
|
Set the configuration epoch in a new node
|
|
For more information see https://redis.io/commands/cluster-set-config-epoch
|
zCLUSTER SET-CONFIG-EPOCHrÅ rÆ )r^ rø rp s rb Úcluster_set_config_epochz2ClusterManagementCommands.cluster_set_config_epoch8 s# ð ×#Ñ#Ø &¨¸Lð $ó
|
ð
|
rd Ústatec óª |j « dv r| j d||||¬« S |j « dk( r t d« t d| « )zÖ
|
Bind an hash slot to a specific node
|
|
:target_node: 'ClusterNode'
|
The node to execute the command on
|
|
For more information see https://redis.io/commands/cluster-setslot
|
)Ú IMPORTINGÚNODEÚ MIGRATINGúCLUSTER SETSLOTrÅ ÚSTABLEz4For "stable" state please use cluster_setslot_stablezInvalid slot state: )rá rt r )r^ rà rÓ rÏ rû s rb Úcluster_setslotz)ClusterManagementCommands.cluster_setslotD se ð ;;=Ð >Ñ >Ø×'Ñ'Ø! 7¨E°7Èð (ó ð ð [[]hÒ &Ü Ð SÓTÐ Tä Ð 3°E°7Ð ;Ó<Ð <rd c ó( | j d|d« S )zÝ
|
Clears migrating / importing state from the slot.
|
It determines by it self what node the slot is in and sends it there.
|
|
For more information see https://redis.io/commands/cluster-setslot
|
r r rÆ rÑ s rb Úcluster_setslot_stablez0ClusterManagementCommands.cluster_setslot_stableX s ð ×#Ñ#Ð$5°wÀÓIÐIrd c ó* | j d||¬« S )z»
|
Provides a list of replica nodes replicating from the specified primary
|
target node.
|
|
For more information see https://redis.io/commands/cluster-replicas
|
zCLUSTER REPLICASrÅ rÆ )r^ rÓ rp s rb Úcluster_replicasz*ClusterManagementCommands.cluster_replicasa s# ð ×#Ñ#Ø °lð $ó
|
ð
|
rd c ó( | j d|¬« S )z
|
Get array of Cluster slot to node mappings
|
|
For more information see https://redis.io/commands/cluster-slots
|
z CLUSTER SLOTSrÅ rÆ rä s rb Ú cluster_slotsz'ClusterManagementCommands.cluster_slotsn s ð ×#Ñ# OÀ,Ð#ÓOÐOrd c ó( | j d|¬« S )z
|
Returns details about the shards of the cluster.
|
|
For more information see https://redis.io/commands/cluster-shards
|
zCLUSTER SHARDSrÅ rÆ rä s rb Úcluster_shardsz(ClusterManagementCommands.cluster_shardsv s ð ×#Ñ#Ð$4À<Ð#ÓPÐPrd c ó( | j d|¬« S )z
|
Returns the shard ID of the node.
|
|
For more information see https://redis.io/commands/cluster-myshardid/
|
zCLUSTER MYSHARDIDrÅ rÆ rä s rb Úcluster_myshardidz+ClusterManagementCommands.cluster_myshardid~ s ð ×#Ñ#Ð$7ÀlÐ#ÓSÐSrd c ó( | j d|¬« S )a
|
Each node in a Redis Cluster maintains a pair of long-lived TCP link with each
|
peer in the cluster: One for sending outbound messages towards the peer and one
|
for receiving inbound messages from the peer.
|
|
This command outputs information of all such peer links as an array.
|
|
For more information see https://redis.io/commands/cluster-links
|
z CLUSTER LINKSrÅ rÆ rÇ s rb Ú cluster_linksz'ClusterManagementCommands.cluster_links s ð ×#Ñ# OÀ+Ð#ÓNÐNrd c ó t d« )NzBCLUSTER FLUSHSLOTS is intentionally not implemented in the client.©ÚNotImplementedErrorrä s rb Úcluster_flushslotsz,ClusterManagementCommands.cluster_flushslots s Ü!Ø Pó
|
ð
|
rd c ó t d« )NzACLUSTER BUMPEPOCH is intentionally not implemented in the client.r rä s rb Úcluster_bumpepochz+ClusterManagementCommands.cluster_bumpepoch s Ü!Ø Oó
|
ð
|
rd c óJ |dk( s|dk( rd| _ | j d|¬« S )zÓ
|
Enables read queries.
|
The command will be sent to the default cluster node if target_nodes is
|
not specified.
|
|
For more information see https://redis.io/commands/readonly
|
ÚreplicasÚallTÚREADONLYrÅ ©rq rt rä s rb Úreadonlyz"ClusterManagementCommands.readonly s3 ð :Ò %¨ ¸Ò)>ð '+DÔ #Ø×#Ñ# J¸\Ð#ÓJÐJrd c ó6 d| _ | j d|¬« S )zÕ
|
Disables read queries.
|
The command will be sent to the default cluster node if target_nodes is
|
not specified.
|
|
For more information see https://redis.io/commands/readwrite
|
FÚ READWRITErÅ r rä s rb Ú readwritez#ClusterManagementCommands.readwriteª s" ð #(Ô Ø×#Ñ# K¸lÐ#ÓKÐKrd r~ )TN)+r§ r¨ r© rª r r¾ rÀ r r rÈ r rÌ rÎ r« rÒ r¬ rÕ r r rÙ rÜ r râ rå rç rë rí rï rò rô r÷ rú r r r r r
|
r r r r r r r® rd rb r¸ r¸ V s4 ñðP¨(ó PðR¨Hó RðO¨ó Oð N¨ð N¸9ó Nð
|
Ø)ð
|
Ø3=ð
|
à ó
|
ð
|
Ø)ð
|
Ø3=ð
|
à ó
|
ð$H¨sð H°yó HðN°Cð N¸Ió Nð R zð R°d¸4±jó Rð E¨Jð E¸9ó Eð DHñVØ)ðVØ3;¸C±=ðVà óVñ0O¨°.Ñ)Að OÈYó Oð< 3ð <¨9ó <ð NRñ
|
Øð
|
Ø "ð
|
Ø2:¸>Ñ2Jð
|
à ó
|
ð5yó 5ð
|
|
Ø *ð
|
|
Ø58ð
|
|
à ó
|
|
ð KOñ
|
Øð
|
Ø/7¸Ñ/Gð
|
à ó
|
ð 8<ñUØ $ ^Ñ 4ðUà óUðM¨Sð M¸Cð MÀIó Mð DHñ
|
|
Øð
|
|
Ø(0° Ñ(@ð
|
|
à ó
|
|
ð=Ø)ð=Ø47ð=ØBEð=ØNQð=à ó=ð(J¨cð J°ió Jð FJñ
|
Øð
|
Ø*2°>Ñ*Bð
|
à ó
|
ñP¨(°>Ñ*Bð PÈió PóQóTð
|
O¨ ð
|
O¸Ió
|
Oñ
|
¨x¸Ñ/Gð
|
ÐSWó
|
ñ
|
|
¨h°~Ñ.Fð
|
ÐRVó
|
ñ
|
K X¨nÑ%=ð KÈó Kñ
|
L h¨~Ñ&>ð
|
LÈ)ô
|
Lrd r¸ c ó& e Zd ZdZdedee fdZy)Ú AsyncClusterManagementCommandsr¹ rÉ rX c óV K t j fd|D « d{ S 7 w)r× c 3 óh K | ]) }t j j d |« « + yw)rØ N)ÚasyncioÚ create_taskrt )Ú.0ra r^ s rb ú <genexpr>zBAsyncClusterManagementCommands.cluster_delslots.<locals>.<genexpr>Ë s2 øè ø ò àô ×#Ñ# D×$8Ñ$8Ð9KÈTÓ$R×Sñùs /2N)r" ÚgatherrÛ s ` rb rÙ z/AsyncClusterManagementCommands.cluster_delslotsÁ s1 øè ø ô ^^óà !ôð
|
÷
|
ð
|
ð
|
ús )¢'£)N)r§ r¨ r© rª r r r rÙ r® rd rb r r · s ñð
|
¨Zð
|
¸DÀ¹Jô
|
rd r c ó¨ e Zd ZdZ dded dededeed ed f d ed
|
ed ee d ed e
|
f fd Z ddee dee dee d efdZ xZS )ÚClusterDataAccessCommandsú¸
|
A class for Redis Cluster Data Access Commands
|
|
The class inherits from Redis's core DataAccessCommand class and do the
|
required adjustments to work with cluster mode
|
ÚstringsÚalgoÚLCSÚvalue1Úvalue2Úspecific_argumentrW ÚlenÚidxÚ minmatchlenÚ withmatchlenrX c
|
ó | j dd« }
|
|dk( r|
|
d}
|
| j d|
|
i« t | ||||||||fi | ¤S )a§
|
Implements complex algorithms that operate on strings.
|
Right now the only algorithm implemented is the LCS algorithm
|
(longest common substring). However new algorithms could be
|
implemented in the future.
|
|
``algo`` Right now must be LCS
|
``value1`` and ``value2`` Can be two strings or two keys
|
``specific_argument`` Specifying if the arguments to the algorithm
|
will be keys or strings. strings is the default.
|
``len`` Returns just the len of the match.
|
``idx`` Returns the match positions in each string.
|
``minmatchlen`` Restrict the list of matches to the ones of a given
|
minimal length. Can be provided only when ``idx`` set to True.
|
``withmatchlen`` Returns the matches with the len of the match.
|
Can be provided only when ``idx`` set to True.
|
|
For more information see https://redis.io/commands/stralgo
|
rp Nr* z default-node)ÚpopÚupdateÚsuperÚstralgo) r^ r+ r- r. r/ r0 r1 r2 r3 r½ rp Ú __class__s rb r8 z!ClusterDataAccessCommands.stralgoÚ sk ø ð> zz .°$Ó7 Ø Ò )¨lÐ.BØ)LØ ~ |Ð4Ô5ÜwØ Ø Ø Ø Ø Ø Ø Ø ñ
|
|
ð ñ
|
|
ð
|
|
rd ÚmatchÚcountÚ_typec
|
+ óB K | j d|||d|¤\ }}|E d { |j « D ci c] \ }}|dk7 s || }}}|r¸|j « D ci c] }|| j |¬« } }|j dd « |ru|j « D ]5 \ }} | j d||||| | d|¤\ }
|
}|E d { |
|
| ||< 7 |j « D ci c] \ }}|dk7 s || }}}|rty y y 7 èc c}}w c c}w 7 Jc c}}w w©N)r: r; r< r )Ú node_namerp )Úcursorr: r; r< rp r® ©Úscanrg rW Úget_noder5 ) r^ r: r; r< r½ ÚcursorsÚdataÚnamer@ ÚnodesÚcurs rb Ú scan_iterz#ClusterDataAccessCommands.scan_iter sN è ø ð " ÐR¨°UÀ%ÑRÈ6ÑR Øà4;·M±M³O×S¡L D¨&ÀvÐQRÃ{4<ÐSÑSÙ àELÇ\Á\Ã^ÖT¸TT4==°4=Ó8Ñ8ÐTEÐTð JJ~ tÔ ,ÙØ$+§M¡M£Oò
|
.LD&Ø ) § ¡ ð !Ø %Ø #Ø #Ø #Ø%*¨4¡[ñ !ð !ñ !ICð $OOØ$'¨¡IGDMð
|
.ð 6=·]±]³_÷Ù%1 T¨6ÈÐRSË D&Lðñ ô ð ð úãSùò Uð $úóùs] D ¡D
|
¢D ¹ D ÁD Á D Á#DÁ=AD Ã DÃ !D Ã. DÃ<DÄD ÄD Ä D ÄD )r* FFNF©NNN)r§ r¨ r© rª r
|
r r r r r« r r8 r r¬ r rI Ú __classcell__)r9 s @rb r( r( Ò s× ø ñð IRØØØ%)Ø "ñ-
|
àenð-
|
ð ð-
|
ð ð -
|
ð
|
! ¨Ñ!3°W¸V±_Ð!DÑEð -
|
ð ð -
|
ð ð-
|
ð c]ð-
|
ð ð-
|
ð
|
õ-
|
ðb %)Ø #Ø #ñ !àÑ!ð!ð }ð!ð }ð !ð
|
÷ !rd r( c óB e Zd ZdZ ddee dee dee defdZ y) Ú AsyncClusterDataAccessCommandsr) Nr: r; r< rX c
|
ól K | j d|||d|¤ d { \ }}|D ] }| |j « D ci c] \ }} | dk7 s || }}} |rÂ|j « D ci c] }|| j |¬« }
|
}|j dd « |r|j « D ]? \ }} | j d| ||||
|
| d|¤ d { \ } }|D ] }| | | ||< A |j « D ci c] \ }} | dk7 s || }}} |r~y y y 7 c c} }w c c}w 7 Zc c} }w wr> rA ) r^ r: r; r< r½ rD rE ÚvaluerF r@ rG rH s rb rI z(AsyncClusterDataAccessCommands.scan_iter7 sw è ø ð (diiÐ X¨e¸5ÈÑ XÐQWÑ X×X Øò EØKð ð 5<·M±M³O×S¡L D¨&ÀvÐQRÃ{4<ÐSÑSÙ àELÇ\Á\Ã^ÖT¸TT4==°4=Ó8Ñ8ÐTEÐTð JJ~ tÔ ,ÙØ$+§M¡M£Oò .LD&Ø&/ d§i¡ið 'Ø %Ø #Ø #Ø #Ø%*¨4¡[ñ 'ð !ñ '÷ !ICð "&ò $Ø # ð$à$'¨¡IGDMð .ð 6=·]±]³_÷Ù%1 T¨6ÈÐRSË D&Lðñ ô ð ð Yûó Tùò Uð !úóùs^ D4D &D4Á D!ÁD!ÁD4Á-D'ÂA
|
D4ÃD,Ã0D4Ä D.ÄD.ÄD4ÄD4Ä! D4Ä.D4rJ )
|
r§ r¨ r© rª r r r« r¬ r rI r® rd rb rM rM - sJ ñð %)Ø #Ø #ñ #àÑ!ð#ð }ð#ð }ð #ð
|
ô #rd rM c ó e Zd ZdZy)ÚRedisClusterCommandsá
|
A class for all Redis Cluster commands
|
|
For key-based commands, the target node(s) will be internally determined
|
by the keys' hash slot.
|
Non-key-based commands can be executed with the 'target_nodes' argument to
|
target specific nodes. By default, if target_nodes is not specified, the
|
command will be executed on the default cluster node.
|
|
:param :target_nodes: type can be one of the followings:
|
- nodes flag: ALL_NODES, PRIMARIES, REPLICAS, RANDOM
|
- 'ClusterNode'
|
- 'list(ClusterNodes)'
|
- 'dict(any:clusterNodes)'
|
|
for example:
|
r.cluster_info(target_nodes=RedisCluster.ALL_NODES)
|
N©r§ r¨ r© rª r® rd rb rQ rQ ] s òrd rQ c ó e Zd ZdZy)ÚAsyncRedisClusterCommandsrR NrS r® rd rb rU rU | s òrd rU ):r" Útypingr r r r r r r r
|
r r r r Ú redis.crcr Úredis.exceptionsr r Ú redis.typingr r r r r r r Úcorer r r r r r r r! r" r# r$ r% r& Úhelpersr' Ú redismodulesr( r) Úredis.asyncio.clusterr* Ú frozensetrr rU r° r¸ r r( rM rQ rU r® rd rb ú<module>r_ s ðÛ ÷ ÷ ÷ ó õ ß >÷÷ ñ ÷÷ ÷ õ õ "ß GáÝ2ñ ò*ó, ô^aAÐ 5ô aAôHL$Ð#:ô L$ô^^LÐ 2ô ^LôB
|
Ø Ð 6ô
|
ô6XÐ 2ô Xôv-Ø Ð 6ô-ô` ØØ ØØØ ØØØØô ô>Ø Ø"ØØ"ØØØØ õrd
|
