ޠj׃ SSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSK J r J r J r J r JrJrJr SSKJrJr SSKJr SSKJr SSKJrJrJrJr SS KJrJrJ r SS K!J"r"J#r# SS K$J%r% SS K&J'r'J(r(J)r) SS K*J+r+J,r, SSK-J.r.J/r/J0r0J1r1 SSK2J3r3J4r4J5r5J6r6J7r7J8r8J9r9J:r:J;r;Jr>J?r?J@r@JArA SSKBJCrC SSKDJErE SSKFJGrGJHrHJIrIJJrJJKrKJLrLJMrM S\NS\\N\O4S\N4SjrP\H"S/SSS9S5rQSrRSrSS\ S\ S\ \\O\O4\ \N\ 444S jrTS!rUS"rVS#rWS$rXS%rYS&rZS'r[S(r\"S)S*\(5r]"S+S,5r^"S-S.\^\#5r_"S/S05r`"S1S2\5ra"S3S45rb"S5S65rc"S7S8\5rd"S9S:\_5reS;\NS\ S<\ 44S=jrfS>rg\gH3rh\hRS?S@5R5rh\k"\e\h\f"\h55 M5 "SASB5rl"SCSD5rmg)EN) OrderedDict)Enum)AnyCallableDictListOptionalTupleUnion)CommandsParserEncoder) parse_scan)default_backoff) CacheConfig CacheFactoryCacheFactoryInterfaceCacheInterface)CaseInsensitiveDictPubSubRedis) READ_COMMANDSRedisClusterCommands) list_or_args)ConnectionPool DefaultParser parse_url)REDIS_CLUSTER_HASH_SLOTSkey_slot)(AfterPooledConnectionsInstantiationEvent'AfterPubSubConnectionInstantiationEvent ClientTypeEventDispatcher)AskErrorAuthenticationErrorClusterCrossSlotErrorClusterDownError ClusterErrorConnectionError DataErrorMasterDownError MovedErrorRedisClusterException RedisError ResponseErrorSlotNotCoveredError TimeoutError TryAgainErrorLock)Retry)HIREDIS_AVAILABLEdeprecated_args dict_mergelist_keys_to_dict merge_resultsafe_str str_if_byteshostportreturncUSU3$)N:r<r=s G/var/www/html/gaurav/venv/lib/python3.13/site-packages/redis/cluster.py get_node_namerD7sV1TF  redis_nodez&Use get_connection(redis_node) instead5.3.0) allowed_argsreasonversionc\UR=(d URR5$N) connectionconnection_poolget_connection)rFargsoptionss rCrOrO;s$  OJ$>$>$M$M$OOrEc n0n/nUR5HupV[U40UD6upxXsU'XH- nM X44$rL)itemsr) commandresrQcursorsret node_nameresponsecursorrs rCparse_scan_resultr\DsIG C"yy{ x373 #   + <rEc [5nUR5HnUHupVX5==U- ss'M M UR5VVs/sHupWXW4PM nnnU$![a XcU'MQf=fs snnfrL)rvaluesKeyErrorrS) rTrUrQnumsub_d numsub_tupschannel numsubbednumsub ret_numsubs rCparse_pubsub_numsubrfOs}Hzz| "- G .!Y.!#.$>;KL;K7#;KJL   .$-! .Ms A  A5 A21A2resprQc ^ URSS5m S[S[[[44U 4Sjjn0nUH.nUSSupVnUSSnU"U6UV s/sHo"U 6PM sn S.X5U4'M0 U$s sn f)N current_hostrPr>c<>[US5=(d TUS4$Nr)r;)rPris rC fix_server'parse_cluster_slots..fix_serveras DG$4 d1g==rE)primaryreplicas)getrr str) rgrQrnslotsslotstartendrqrrreplicaris @rCparse_cluster_slotsrz\s;;~r2L>#>%S/> E"2AhG8!7+=EFX'W-XF Sj LGs A-c [US[5(aU$/nUHn//S.n[S[US5S5H(nUSR USUUSUS-45 M* USnUHBn0n[S[U5S5HnXuS-XU'M USR U5 MD UR U5 M U$)z Parse CLUSTER SHARDS response. r)runodesrmrurpr|) isinstancedictrangelenappend) rgrQshardsxshardir|node dict_nodes rCparse_cluster_shardsrps$q'4   F r*q#ad)Q'A 'N ! !1Q47QqT!a%[": ;(!DI1c$i+%)a%[ q'", 'N ! !) ,   e MrEc $URS5$)z# Parse CLUSTER MYSHARDID response. utf-8)decode)rgrQs rCparse_cluster_myshardidrs ;;w rErqryzslot-id)&charsetconnection_classrNconnection_pool_class client_namecredential_providerdbdecode_responsesencodingencoding_errorserrorsr<lib_name lib_versionmax_connections nodes_flagredis_connect_funcpasswordr= queue_classretryretry_on_timeoutprotocolsocket_connect_timeoutsocket_keepalivesocket_keepalive_optionssocket_timeoutssl ssl_ca_certs ssl_ca_data ssl_certfile ssl_cert_reqs ssl_keyfile ssl_passwordunix_socket_pathusernamecache cache_configrBc UR5VVs0sHupU[;dMU[;dMX_M! nnnU$s snnf)z1 Remove unsupported or disabled keys from kwargs )rSREDIS_ALLOWED_KEYSKWARGS_DISABLED_KEYS)kwargskvconnection_kwargss rCcleanup_kwargsrsT LLN"DA " " '(0D'D "  s >>>c H\rSrSr\"\R \\\ \ \ \ S.5rSr g) ClusterParser)ASKTRYAGAINMOVED CLUSTERDOWN CROSSSLOT MASTERDOWNrAN)__name__ __module__ __qualname____firstlineno__r7rEXCEPTION_CLASSESr#r1r+r&r%r*__static_attributes__rArErCrrs-"''%+.)   rErc\rSrSrSrSrSrSrSrSr \\\\\ 1r \ "\ "/SQ\ 5\ "/S Q\5\ "S /\5\ "/S Q\ 55r/S Q4r\\\S .r\ "\ "SS/\5\ "S/S5\ "/SQ\5\ "/SQS5\ "SS/S5\ "S/S5\ "S/\5\ "S/S5\ "S/S5\ "S/S 55 r\\\\4rS$S%S"jjrS#rg!)&AbstractRedisCluster primariesrrallrandomz default-node)WzACL CATz ACL DELUSERz ACL DRYRUNz ACL GENPASSz ACL GETUSERzACL HELPzACL LISTzACL LOGzACL LOADzACL SAVEz ACL SETUSERz ACL USERSz ACL WHOAMIAUTH CLIENT LISTzCLIENT SETINFOCLIENT SETNAMECLIENT GETNAME CONFIG SETCONFIG REWRITECONFIG RESETSTATTIMEPUBSUB CHANNELS PUBSUB NUMPAT PUBSUB NUMSUBPUBSUB SHARDCHANNELSPUBSUB SHARDNUMSUBPINGINFOSHUTDOWNKEYSDBSIZEBGSAVE SLOWLOG GET SLOWLOG LEN SLOWLOG RESETWAITWAITAOFSAVE MEMORY PURGEzMEMORY MALLOC-STATSz MEMORY STATSLASTSAVEzCLIENT TRACKINGINFO CLIENT PAUSECLIENT UNPAUSECLIENT UNBLOCKz CLIENT IDz CLIENT REPLYzCLIENT GETREDIRz CLIENT INFO CLIENT KILLREADONLYz CLUSTER INFOz CLUSTER MEETCLUSTER MYSHARDIDz CLUSTER NODESzCLUSTER REPLICASz CLUSTER RESETzCLUSTER SET-CONFIG-EPOCH CLUSTER SLOTSCLUSTER SHARDSzCLUSTER COUNT-FAILURE-REPORTSzCLUSTER KEYSLOTCOMMANDz COMMAND COUNTz COMMAND LISTzCOMMAND GETKEYS CONFIG GETDEBUG RANDOMKEYr READWRITErzTFUNCTION LOADzTFUNCTION DELETEzTFUNCTION LISTTFCALL TFCALLASYNCz GRAPH.CONFIGzLATENCY HISTORYzLATENCY LATESTz LATENCY RESETz MODULE LISTz MODULE LOADz MODULE UNLOADz MODULE LOADEX) FLUSHALLFLUSHDBzFUNCTION DELETEzFUNCTION FLUSHz FUNCTION LISTz FUNCTION LOADzFUNCTION RESTOREzREDISGEARS_2.REFRESHCLUSTERSCAN SCRIPT EXISTS SCRIPT FLUSH SCRIPT LOADz FUNCTION DUMP)zCLUSTER COUNTKEYSINSLOTzCLUSTER DELSLOTSzCLUSTER DELSLOTSRANGEzCLUSTER GETKEYSINSLOTzCLUSTER SETSLOT)z FT.CREATEz FT.SEARCHz FT.AGGREGATEz FT.EXPLAINz FT.EXPLAINCLIz FT,PROFILEzFT.ALTERz FT.DROPINDEXz FT.ALIASADDzFT.ALIASUPDATEz FT.ALIASDELz FT.TAGVALSz FT.SUGADDz FT.SUGGETz FT.SUGDELz FT.SUGLENz FT.SYNUPDATEz FT.SYNDUMPz FT.SPELLCHECKz FT.DICTADDz FT.DICTDELz FT.DICTDUMPzFT.INFOzFT._LISTz FT.CONFIGzFT.ADDzFT.DELzFT.DROPzFT.GETzFT.MGETz FT.SYNADD)rrrrrrcF[[UR555$rL)sumlistr^rTrUs rCAbstractRedisCluster.sCSZZ\8J4KrE)rrr) rrrrrrrrrrrcb[U[5(a[UR55$U$rL)r~rrr^rs rCrr$jd6K6KSZZ\!2!TQT!TrErrcb[U[5(a[UR55$U$rL)r~rrr^rs rCrrrrErcD[UR55S:aS$S$rl)rr^rs rCrrs#cjjl:Ka:OQ5VUV5VrErrcP[UR55R5$rL)rr^poprs rCrrs$szz|2D2H2H2JrErcj[UR56Vs/sHn[U5PM sn$s snfrL)zipr^r)rTrUrs rCrrs'S#**,EW4XEWSVEW4X4Xs0rc4[UR55$rL)rr^rs rCrrsSZZ\ARrENcU(aXRlgUR5nUR5Vs/sH o3U:wdM UPM nnU(a&[R "U5URlgUR 5Vs/sH o3U:wdM UPM nnU(a&[R "U5URlggs snfs snf)aGReplace the default cluster node. A random cluster node will be chosen if target_node isn't passed, and primaries will be prioritized. The default node will not be changed if there are no other nodes in the cluster. Args: target_node (ClusterNode, optional): Target node to replace the default node. Defaults to None. N) nodes_manager default_nodeget_default_node get_primariesrchoice get_replicas)self target_node curr_noderrrrs rCreplace_default_node)AbstractRedisCluster.replace_default_nodes .9   +--/I*.*<*<*>T*>$)BS*>IT28-- 2J""/.2->->-@V-@TIDUD-@V6N)rrrrRedisClusterRequestTTL PRIMARIESREPLICAS ALL_NODESRANDOM DEFAULT_NODE NODE_FLAGSr7r8SLOT_ID COMMAND_FLAGSSEARCH_COMMANDSrzrr#CLUSTER_COMMANDS_RESPONSE_CALLBACKSrfr9r\RESULT_CALLBACKSr(r0r&r/ERRORS_ALLOW_RETRYrrrArErCrrsIHI F!LXy&,GJX r u[ x    " ?+V4   _yMx "OJ-.4+' "?,@ACVW  K   ?    U  v  T     V  6($56 OJ    X  >*,RSM'T  NNrErc! \rSrSr\S5r\"S/SSS9S@S\\S \ S \\ S S \ S \SS\ S\ S\ S\SS\ S\\S\\ \ \\ 4/\ \\ 44S\\S\\S\\4Sjj5rSrSrSrSrSrSrSAS jrS!rS"rS#rS$rSBS%jrS&rS'rS(\S4S)jr SCS*jr!SDS+jr"SAS,jr#SES-jr$SFS.jr%S/r&S(\ S 4S0jr'S1r(S2r)S3r*S4r+S5r,S6r-S7r.S8r/S9r0S:r1S;r2SGS<jr3S=r4S>r5S?r6g)H RedisClusteric U"SSU0UD6$)a5 Return a Redis client object configured from the given URL For example:: redis://[[username]:[password]]@localhost:6379/0 rediss://[[username]:[password]]@localhost:6379/0 unix://[username@]/path/to/socket.sock?db=0[&password=password] Three URL schemes are supported: - `redis://` creates a TCP socket connection. See more at: - `rediss://` creates a SSL wrapped TCP socket connection. See more at: - ``unix://``: creates a Unix Domain Socket connection. The username, password, hostname, path and all querystring values are passed through urllib.parse.unquote in order to replace any percent-encoded values with their corresponding characters. There are several ways to specify a database number. The first value found will be used: 1. A ``db`` querystring option, e.g. redis://localhost?db=0 2. If using the redis:// or rediss:// schemes, the path argument of the url, e.g. redis://localhost/0 3. A ``db`` keyword argument to this function. If none of these options are specified, the default db=0 is used. All querystring options are cast to their appropriate Python types. Boolean arguments can be specified with string values "True"/"False" or "Yes"/"No". Values that cannot be properly cast cause a ``ValueError`` to be raised. Once parsed, the querystring arguments and keyword arguments are passed to the ``ConnectionPool``'s class initializer. In the case of conflicting arguments, querystring arguments always win. urlrArA)clsr+rs rCfrom_urlRedisCluster.from_urlsT%s%f%%rEread_from_replicasz6Please configure the 'load_balancing_strategy' insteadrG args_to_warnrIrJNr<r= startup_nodesrcluster_error_retry_attemptsrr4require_full_coveragereinitialize_stepsload_balancing_strategyLoadBalancingStrategydynamic_startup_nodesr+ address_remaprrevent_dispatcherc Uc/nSU;a [S5eSnU bSn[U 5nSU;a [S5eSU;aUSS:wa [S 5eURU5 URS 5nURS U5nUR [ X55 O;UbUbUR [ X55 O[ U5S:Xa [S 5eURS S5UlURS UR05 [S0UD6nU(a$XPl URSUR05 O%URS[[5S505 [URSS5URSS5URSS55UlURSS5nU(dU (aUS;a [!S5eX@lUR$R&R)5UlUR$R,R)5UlXlXlSUlXplUc[95UlOXl[=SUUUU U U UUR:S.UD6Ul[AUR$RB5Ul"[AUR$RF5Ul$[KU5Ul&[NRP"5Ul)g)a Initialize a new RedisCluster client. :param startup_nodes: List of nodes from which initial bootstrapping can be done :param host: Can be used to point to a startup node :param port: Can be used to point to a startup node :param require_full_coverage: When set to False (default value): the client will not require a full coverage of the slots. However, if not all slots are covered, and at least one node has 'cluster-require-full-coverage' set to 'yes,' the server will throw a ClusterDownError for some key-based commands. See - https://redis.io/topics/cluster-tutorial#redis-cluster-configuration-parameters When set to True: all slots must be covered to construct the cluster client. If not all slots are covered, RedisClusterException will be thrown. :param read_from_replicas: @deprecated - please use load_balancing_strategy instead Enable read from replicas in READONLY mode. You can read possibly stale data. When set to true, read commands will be assigned between the primary and its replications in a Round-Robin manner. :param load_balancing_strategy: Enable read from replicas in READONLY mode and defines the load balancing strategy that will be used for cluster node selection. The data read from replicas is eventually consistent with the data in primary nodes. :param dynamic_startup_nodes: Set the RedisCluster's startup nodes to all of the discovered nodes. If true (default value), the cluster's discovered nodes will be used to determine the cluster nodes-slots mapping in the next topology refresh. It will remove the initial passed startup nodes if their endpoints aren't listed in the CLUSTER SLOTS output. If you use dynamic DNS endpoints for startup nodes but CLUSTER SLOTS lists specific IP addresses, it is best to set it to false. :param cluster_error_retry_attempts: Number of times to retry before raising an error when :class:`~.TimeoutError` or :class:`~.ConnectionError` or :class:`~.ClusterDownError` are encountered :param reinitialize_steps: Specifies the number of MOVED errors that need to occur before reinitializing the whole cluster topology. If a MOVED error occurs and the cluster does not need to be reinitialized on this current error handling, only the MOVED slot will be patched with the redirected node. To reinitialize the cluster on every MOVED error, set reinitialize_steps to 1. To avoid reinitializing the cluster on moved errors, set reinitialize_steps to 0. :param address_remap: An optional callable which, when provided with an internal network address of a node, e.g. a `(host, port)` tuple, will return the address where the node is reachable. This can be used to map the addresses at which the nodes _think_ they are, to addresses at which a client may reach them, such as when they sit behind a proxy. :**kwargs: Extra arguments that will be sent into Redis instance when created (See Official redis-py doc for supported kwargs [https://github.com/andymccurdy/redis-py/blob/master/redis/client.py]) Some kwargs are not supported and will raise a RedisClusterException: - db (Redis do not support database SELECT in cluster mode) Nrz4Argument 'db' is not possible to use in cluster modeFTpathzFRedisCluster does not currently support Unix Domain Socket connectionsrz9A ``db`` querystring option can only be 0 in cluster moder<r=a5RedisCluster requires at least one node to discover the cluster. Please provide one of the followings: 1. host and port, for example: RedisCluster(host='localhost', port=6379) 2. list of startup nodes, for example: RedisCluster(startup_nodes=[ClusterNode('localhost', 6379), ClusterNode('localhost', 6378)])rrrrrstrictrr)rp3z4Client caching is only supported with RESP version 3)r2r-r4r8r9rrr:rA)*r,rupdatersrrrr user_on_connect_func on_connectrrr4rr encoderr-r3 __class__r#copy command_flagsr! node_flagsr/r6reinitialize_counterr5r"_event_dispatcher NodesManagerrrr%cluster_response_callbacksr&result_callbacksr commands_parser threadingr3_lock)rr<r=r2r3rr4r5r/r6r8r+r9rrr:rr- url_optionsrs rC__init__RedisCluster.__init__sv  M 6>'F   ?H#C.K$+){"{4'8A'=+O MM+ &::f%D::fd+D  T!8 9  $"2  T!8 9  1 $'4 %+JJ/CT$J! +T__=>)&) J MM7DJJ/ 0 MM7E/*;Q$?@ A JJz7 + JJ(( 3 JJ)5 1  ::j$/ Exx'?ST T,H)!^^99>>@..3388:"4'>$$%!"4  #%4%6D "%5 ")  '"7"7'%!33    +> NN > >+ '!4DNN4S4S T-d3^^% rEcU$rLrArs rC __enter__RedisCluster.__enter__s rEc$UR5 grLcloserexc_type exc_value tracebacks rC__exit__RedisCluster.__exit__  rEc$UR5 grLrWrSs rC__del__RedisCluster.__del__r_rEcUR5H;nUR(dMURRR5 M= g![a MMf=frL) get_nodesredis_connectionrN disconnectOSErrorrrs rCdisconnect_connection_pools(RedisCluster.disconnect_connection_poolssPNN$D$$$))99DDF%s$A AAcBUR[5 UR5 UR(dUR(a9UR S5 [ UR55S:wa [S5eURbURU5 gg)z} Initialize the connection, authenticate and select a database and send READONLY if it is set during object initialization. rOKzREADONLY command failedN) set_parserrrAr/r6 send_commandr; read_responser(r@)rrMs rCrARedisCluster.on_connects m,  " "d&B&B  # #J /J44674?%&?@@  $ $ 0  % %j 1 1rEcUR(dNUR UR(dURRU/5 SSS5 UR$UR$!,(df  UR$=frL)rerNrcreate_redis_connectionsrhs rCget_redis_connection!RedisCluster.get_redis_connectionse$$,,&&??G$$$t$$$$$$s .A,, Bc:URRXU5$rL)rget_noderr<r=rXs rCrvRedisCluster.get_nodes!!**4yAArEc@URR[5$rL)rget_nodes_by_server_typePRIMARYrSs rCrRedisCluster.get_primaries!!::7CCrEc@URR[5$rL)rrzREPLICArSs rCrRedisCluster.get_replicasr}rEc[R"[URRR 555$rL)rrrr nodes_cacher^rSs rCget_random_nodeRedisCluster.get_random_nodes+}}T$"4"4"@"@"G"G"IJKKrEc\[URRR55$rL)rrrr^rSs rCrdRedisCluster.get_nodess"D&&2299;<cUR$rL)rrSs rC get_retryRedisCluster.get_retrys zzrEctXlUR5HnURRU5 M grL)rrdre set_retry)rrrs rCrRedisCluster.set_retrys, NN$D  ! ! + +E 2%rEcUcUR5nURc[SURS35eURR 5$)a1 Returns a Monitor object for the specified target node. The default cluster node will be selected if no target node was specified. Monitor is useful for handling the MONITOR command to the redis server. next_command() method returns one command from monitor listen() method yields commands from monitor. z Cluster Node z has no redis_connection)rrer,rmonitor)rrs rCrRedisCluster.monitor!s\  //1K  ' ' /' 0 011IJ ++3355rEc [U4XUS.UD6$)zf Allows passing a ClusterNode, or host&port, to get a pubsub instance connected to the specified node )rr<r=) ClusterPubSub)rrr<r=rs rCpubsubRedisCluster.pubsub2s TMdMfMMrEc JU(a [S5eU(a [S5e[URURURRUR UR URURURURURS9 $)a+ Cluster impl: Pipelines do not work in cluster mode the same way they do in normal mode. Create a clone of this object so that simulating pipelines will work correctly. Each command will be called directly when used and when calling execute() will only return the result stack. z(shard_hint is deprecated in cluster modez)transaction is deprecated in cluster mode) rrLr2rKrJr3r/r6r5lock) r,ClusterPipelinerrLr2rKrJr3r/r6r5rN)r transaction shard_hints rCpipelineRedisCluster.pipeline9s '(RS S '(ST T,, 00,,::!22'+'F'F)-)J)J#66$($@$@#66  rEc ,Uc[nU"UUUUUUUS9$)a Return a new Lock object using key ``name`` that mimics the behavior of threading.Lock. If specified, ``timeout`` indicates a maximum life for the lock. By default, it will remain locked until release() is called. ``sleep`` indicates the amount of time to sleep per loop iteration when the lock is in blocking mode and another client is currently holding the lock. ``blocking`` indicates whether calling ``acquire`` should block until the lock has been acquired or to fail immediately, causing ``acquire`` to return False and the lock not being acquired. Defaults to True. Note this value can be overridden by passing a ``blocking`` argument to ``acquire``. ``blocking_timeout`` indicates the maximum amount of time in seconds to spend trying to acquire the lock. A value of ``None`` indicates continue trying forever. ``blocking_timeout`` can be specified as a float or integer, both representing the number of seconds to wait. ``lock_class`` forces the specified lock implementation. Note that as of redis-py 3.0, the only lock class we implement is ``Lock`` (which is a Lua-based lock). So, it's unlikely you'll need this parameter, unless you have created your own custom lock class. ``thread_local`` indicates whether the lock token is placed in thread-local storage. By default, the token is placed in thread local storage so that a thread only sees its token, not a token set by another thread. Consider the following timeline: time: 0, thread-1 acquires `my-lock`, with a timeout of 5 seconds. thread-1 sets the token to "abc" time: 1, thread-2 blocks trying to acquire `my-lock` using the Lock instance. time: 5, thread-1 has not yet completed. redis expires the lock key. time: 5, thread-2 acquired `my-lock` now that it's available. thread-2 sets the token to "xyz" time: 6, thread-1 finishes its work and calls release(). if the token is *not* stored in thread local storage, then thread-1 would see the token value as "xyz" and would be able to successfully release the thread-2's lock. In some use cases it's necessary to disable thread local storage. For example, if you have code where one thread acquires a lock and passes that lock instance to a worker thread to release later. If thread local storage isn't disabled in this case, the worker thread won't see the token set by the thread that acquired the lock. Our assumption is that these cases aren't common and as such default to using thread local storage.)timeoutsleepblockingblocking_timeout thread_localr2)rrrrrr lock_classrs rCrRedisCluster.lockUs2|  J  -%  rEc X RU'g)zSet a custom Response CallbackN)rJ)rrTcallbacks rCset_response_callback"RedisCluster.set_response_callbacks3;''0rEcUSR5n[U5S:aDUSSUS3R5UR;aUSSUS3R5nURSS5nUbUnOURR U5nXPR R :XaUR5/$XPR R:XaUR5$XPR R:XaUR5$XPR R:XaUR5$XPR R:XaURR /$X0R R"S;aURR /$UR$"U6nURR'UUR(=(a U[*;U[*;a UR,OS5nU/$)Nrr} rmr)upperrrEr rsrCrrrrrrrrdr rrr$determine_slotget_node_from_slotr/rr6)rrPrrTr command_flagrvrs rC_determine_nodesRedisCluster._determine_nodessq'--/ t9>a 47)4::<@R@RRa 47),224GZZ d3  !%L --11':L >>00 0((*+ + ^^55 5%%' ' ^^44 4$$& & ^^55 5>># # ^^88 8&&334 4 66q9 9&&334 4&&-D%%88''DG},D07=0H,,dD 6MrEc\URS:XagURUR-S:H$)NrF)r5rGrSs rC_should_reinitialized"RedisCluster._should_reinitializeds1  " "a ',,t/F/FF!K KrEcNURRU5n[U5$)zh Calculate keyslot for a given key. See Keys distribution model in https://redis.io/topics/cluster-spec )rBencoder)rrrs rCrRedisCluster.keyslots" LL   ${rEcpUR5RnURR"U/UQ76$)ac Get the keys in the command. If the command has no keys in in, None is returned. NOTE: Due to a bug in redis<7.0, this function does not work properly for EVAL or EVALSHA when the `numkeys` arg is 0. - issue: https://github.com/redis/redis/issues/9493 - fix: https://github.com/redis/redis/pull/9733 So, don't use this function with EVAL or EVALSHA. )rrerLget_keys)rrP redis_conns rC_get_command_keysRedisCluster._get_command_keyss4**,== ##,,Z?$??rEcUSnURRU5[:XaUS$UR5S;a`[ U5S::a[ SU35e[ US5nUSSU-n[ U5S:Xa[R"S[5$UnO^UR"U6nUb[ U5S:Xa=UR5S;a[R"S[5$[ SU35e[ U5S:XaURUS5$UVs1sHo`RU5iM nn[ U5S:wa[ US 35eUR5$s snf) z Figure out what slot to use based on args. Raises a RedisClusterException if there's a missing key and we can't determine what slots to map the command to; or, if the keys don't all map to the same key slot. rrm)EVALEVALSHAr}zInvalid args in command: rp)FCALLFCALL_ROzNo way to dispatch this command to Redis Cluster. Missing key. You can execute the command by specifying target nodes. Command: z) - all keys must map to the same key slot) rErsr"rrr,intr randrangerrrr )rrPrTnum_actual_keys eval_keyskeysrrus rCrRedisCluster.determine_slotsvq'    ! !' *g 57N ==?1 14yA~+.Gv,NOO!$q'lOQ_!45I9~"''+CDDD))40D|s4yA~==?&;;!++A/GHH+//3f6 t9><<Q( (/33dsc"d3 u:?')DE yy{ 4s'E/cUR$)z Get the connections' encoder )rBrSs rC get_encoderRedisCluster.get_encoder&s||rEc.URR$)z) Get the connections' key-word arguments )rrrSs rCget_connection_kwargs"RedisCluster.get_connection_kwargs,s!!333rEcL[U[5=(a XR;$rL)r~rtrF)r target_nodess rC_is_nodes_flagRedisCluster._is_nodes_flag2s,,P1PPrEc[U[5(aUnU$[U[5(aU/nU$[U[5(aUR 5nU$[ S[ U535e)Nztarget_nodes type can be one of the following: node_flag (PRIMARIES, REPLICAS, RANDOM, ALL_NODES),ClusterNode, list, or dict. The passed type is )r~rrrr^ TypeErrortype)rrr|s rC_parse_target_nodes RedisCluster._parse_target_nodes5s lD ) ) E   k 2 2!NE  d + +!'')E &'+<&8%9; rEc&UR"U0UD6$rL)_internal_execute_commandrrPrs rCexecute_commandRedisCluster.execute_commandIs--t>v>>rEcSnSnSnURSS5nUb)URU5(dURU5nSnU(aSO URnSU-n[ U5Hn 0n U(dTUR "U0UDSU0D6nU(d[ SUS 35e[U5S:XaUSUR5:XaSnUH%n UR"U /UQ70UD6XR'M' UR"USU 40UD6s $ g![aRn US:aE[U 5URR;a"U(aUR!5 US-nSn A MU eSn A ff=f) a Wrapper for ERRORS_ALLOW_RETRY error handling. It will try the number of times specified by the config option "self.cluster_error_retry_attempts" which defaults to 3 unless manually configured. If it reaches the number of times, the command will raise the exception Key argument :target_nodes: can be passed with the following types: nodes_flag: PRIMARIES, REPLICAS, ALL_NODES, RANDOM ClusterNode list dict FNrTrrmr!No targets were found to execute command on)r rrr3rrr,rr_execute_commandr_process_result ExceptionrrCr'r) rrPrtarget_nodes_specifiedis_default_noderpassed_targetsretry_attemptsexecute_attempts_rUres rCr&RedisCluster._internal_execute_commandLs "' ND9  %d.A.A..Q.Q33NCL%) "(AT-N-N ~-'(A -#'#8#8$!'$4B$L(3?v[QL)Q.(Ot/D/D/FF*.(D%)%:%:4%Q$%Q&%QC N)++DGSCFCC))* !A%$q'T^^5V5V*V&113#a'NG s .BD E.AE)'E))E.cLUSnSnSnSnSnSn [UR5n U S:GaIU S-n U(aURUS9nOeU (a^UR"U6n URR U UR =(a U[;U[;a UROS5nSn URU5n[U5nU(a'URS5 UR"US40UD6 SnUR"U0UD6 UR"Xd40UD6n URSS5 X@R;aURU"U 40UD6n U UbURR!U5 $$[QS 5e!["a e[$[&4akn UbUR)5 URR*RUR,S5 SUlURR15 U eSn A f[2asn U=R4S- slUR75(a"URR15 SUlOURR9U 5 Sn Sn A OSn A f[:a+ XRS - :a[<R>"S 5 O[@a*n [CU RDU RFS 9nSnSn A OxSn A f[H[J4a2 [<R>"S 5 URR15 e[La e[Nan U(aUR)5 U eSn A ff=fUbURR!U5 O$!UbURR!U5 ff=fU S:aGMxGN1)z) Send a command to a node in the cluster rNFrmrASKINGrTr}g?rBg?zTTL exhausted.))rrrvrrrr/rr6rsrOrnparse_responser rJrNreleaser$r(r0rfr2rre initializer+rGrupdate_moved_exceptionr1timerr#rDr<r=r&r/r.rr')rrrPrrTrFrM redirect_addraskingmovedttlrvrYrs rCrRedisCluster._execute_commandsbq'   $--.Ag 1HCa C"&----"HK ..5D"&"4"4"G"G//LG}4L '-7!88!% #K"E!66{C +J7 ++H5--j(MfM"F''88%44ZSFS 64(===#>>wG  $* H |)..66zB*+,,A' #\2  )))+""0044[5E5EtL/3 ,""--/ ))Q.)--//&&11301D-&&==a@  %44q88JJt$  -166 G $&9:  4 ""--/   ))+  )..66zB)..66zB*EAggscD#FMA&H M A)I;6M7;5M0M72 M; K M7 AM7MMM77!NcUR UR(aURR5 SSS5 g!,(df  g=f![a gf=frL)rNrrXAttributeErrorrSs rCrXRedisCluster.closesF %%&&,,.   s- A,AA A AA A! A!c XR;aURU"X40UD6$[U5S:Xa[UR55S$U$)z Process the result of the executed command. The function would return a dict or a single value. :type command: str :type res: dict `res` should be in the following format: Dict rmr)rKrrr^)rrTrUrs rCrRedisCluster._process_resultsS ++ +((1'I&I I X] %a( (JrEc[XU5 g)z This function can be used to add externally defined redis modules, and their namespaces to the redis client. ``funcname`` - A string containing the name of the function to create ``func`` - The function, being added to this class. N)setattr)rfuncnamefuncs rCload_external_module!RedisCluster.load_external_module"s %rE)rHrNr3rJrErLrBr6rFrr/rGr5rKrr@)NiNrpNFFNTNNNNNNNN)F)rr4r>NrLNN)Ng?TNNTr>N)7rrrr classmethodr-r6r rtrrboolrr rrr"rPrTr]rarirArsrvrrrrdrrrrrrrrrrrrrrrrrrrrrrrXrr rrArErCr)r)sM)&)&V*+G#7;,-#'&+"##(EI&*!PT*..26:!s&sms&s& ] 34 s& '* s&  s& $s& s&!s&"**A!Bs& $s&c]s& %S/):E#s(O)K LMs&'s&{+s& #?3!s&  s&j2*%BDDL=$(/ 8G,3 6"N >H T<'4 3F'RL @7r 4 Q(?DLq-f(&rEr)c0\rSrSrSSjrSrSrSrSrg) ri-NcUS:Xa[R"U5nXlX l[ X5UlX0lX@lg)N localhost)socket gethostbynamer<r=rDr server_typere)rr<r=rres rCrPClusterNode.__init__.s< ; ''-D  !$- & 0rEc SURSURSURSURSURS3 $)Nz[host=z,port=z,name=z ,server_type=z,redis_connection=])r<r=rrrerSs rC__repr__ClusterNode.__repr__8sWTYYK II;II;++,- $ 5 56a  9 rEcb[U[5=(a URUR:H$rL)r~rr)robjs rC__eq__ClusterNode.__eq__As!#{+EDII0EErEcTURbURR5 ggrL)rerXrSs rCraClusterNode.__del__Ds%  ,  ! ! ' ' ) -rE)r<rr=rerr) rrrrrPrr!rarrArErCrr-s1 F*rErc \rSrSrSrSrSrSrg)r7iI round_robinround_robin_replicasrandom_replicarAN)rrrr ROUND_ROBINROUND_ROBIN_REPLICASRANDOM_REPLICArrArErCr7r7IsK1%NrEr7c \rSrSrSrSS\SS4Sjjr\R4S\ S\S \S\4S jjr SS jr S\S\4S jr S\ S\S \ S\4SjrSrg) LoadBalanceriOz Round-Robin Load Balancing start_indexr>Nc0UlXlgrLprimary_to_idxr.)rr.s rCrPLoadBalancer.__init__Ts &rErq list_sizer6cU[R:XaURU5$URUUU[R:H5$rL)r7r+_get_random_replica_index_get_round_robin_indexr*)rrqr3r6s rCget_server_indexLoadBalancer.get_server_indexXsL #&;&J&J J11)< <..'+@+U+UU rEc8URR5 grL)r1clearrSs rCresetLoadBalancer.resetgs !!#rEc6[R"SUS- 5$)Nrm)rrandint)rr3s rCr5&LoadBalancer._get_random_replica_indexjs~~aQ//rE replicas_onlycURRXR5nU(aUS:XaSnUS-U-URU'U$rl)r1 setdefaultr.)rrqr3r@ server_indexs rCr6#LoadBalancer._get_round_robin_indexmsO**55g?O?OP \Q.L(4q(8I'EG$rEr0)rr)rrrr__doc__rrPr7r)rtr7r;r5rr6rrArErCr-r-Os'C'':O9Z9Z   "7  $03030  '* ;?   rEr-c \rSrSrSSSS\SSSSS4 S\\\\\ 4/\\\ 44S\\ S\\ S\\ S \\ 4 S jjrS!S jrS rS r\"S/SSS9S"Sj5rSrSrSrSrSrSrSrS#SjrSrS\S\ S\\\ 44SjrS rg)$rIiyFNTr9rr cache_factoryr:c  0Ul0Ul0UlSUlUR U5 X lX0lXPlX`lXpl Xl Xl Xl SUl Xl[5UlUc["R$"5nX@lU c[)5UlOXlURR-SS5UlUR15 g)Nr)rrr2rpopulate_startup_nodesr-_require_full_coverage_dynamic_startup_nodesrr9_cache _cache_config_cache_factory_moved_exceptionrr-read_load_balancerrMr3rNr"rHrs_credential_providerr) rr2r-r4rr8rr9rrrGr:rs rCrPNodesManager.__init__zs  ##M2 &;#&;#%:"* )+ $!'".. <>>#D  #%4%6D "%5 "$($:$:$>$> !4% ! rEcU(aEU(a>US:Xa[R"U5nURR[ XS95$U(aURRU5$g)zl Get the requested node from the cluster's nodes. nodes. :return: ClusterNode if the node exists, else None rrBN)rrrrsrDrws rCrvNodesManager.get_nodesZ D{"++D1##'' 4(KL L ##'' 2 2rEcXlgrL)rO)r exceptions rCr#NodesManager.update_moved_exceptions )rEcURnURURURS9nUbUR[ La [ UlO=[ URUR[ 5nX RUR'X RUR;aURURSn[UlURURRU5 URURRU5 X RURS'URU:XaX lOU/URUR'SUlg)z0 Update the slot's node with the redirected one rBNr)rOrvr<r=rr{rrrrslot_idrrremover)rrredirected_node old_primarys rC_update_moved_slots NodesManager._update_moved_slotss5  ! !--QVV!&&-A  &**'9.5+*!&&!&&'BO5D  _11 2 ..qyy9 9**1995a8K'.K #   QYY ' . .{ ;   QYY ' . . ?-<  QYY ' *  K/$3! ,;*;D  QYY ' $rErz|In case you need select some load balancing strategy that will use replicas, please set it through 'load_balancing_strategy'rGr0cNUR(a6UR UR(aUR5 SSS5 URR U5b[ URU5S:Xa[ SUSURS35eUSLaUc[Rn[ URU5S:aWU(aPURUSRnURRU[ URU5U5nO\Ub&U[:Xd[ URU5S:XaSnO0[R"S[ URU5S- 5nURUU$!,(df  GN\=f)z) Gets a node that servers this hash slot Nrrz5" not covered by the cluster. "require_full_coverage="Trm)rOrNr]rrsrr/rJr7r)rrPr7r{rr>)rrvr/r6r primary_namers rCrNodesManager.get_node_from_slots$  ((,,.      % -T5E5Ed5K1LPQ1Q%**.*E*E)FaI   %*A*I&;&G&G # t% & */F++D1!499L..??c$"2"24"89;RH  g%4##D)*a/H~~aT-=-=d-C)Dq)HIH%h//?s "F F$cURR5Vs/sHnURU:XdMUPM sn$s snf)zv Get all nodes with the specified server type :param server_type: 'primary' or 'replica' :return: list of ClusterNode )rr^r)rrrs rCrz%NodesManager.get_nodes_by_server_typesF((//1 1;. 1   s==cFUHnX RUR'M g)z; Populate all startup nodes and filters out any duplicates N)r2r)rr|ns rCrI#NodesManager.populate_startup_nodess A)*  qvv &rEc@[S[5H nX!;dM g g)NrFT)rr)rrrs rCcheck_slots_coverage!NodesManager.check_slots_coverage&s$q23A#4rEcn/nUHonURbMUR"SURURS.URD6UlUR URR 5 Mq URR[U[RUR55 g)zF This function will create a redis connection to all nodes in :nodes: NrBrA) recreate_redis_noder<r=rrrNrHdispatchrr!SYNCrQ)rr|connection_poolsrs rCrr%NodesManager.create_redis_connections.sD$$,(,(>(>))6:6L6L)%!''(=(=(M(MN  '' 4 *//43L3L  rEc UR(a^URSU05 URSU05 URSUR05 [UR"S0UD6S9nU$[SUUURS.UD6nU$)Nr<r=r)rN)r<r=rrA)r-r?rLrr)rr<r=rr[s rCrlNodesManager.create_redis_node@s == MM64. ) MM64. ) MM7DKK0 1d&@&@&J6&JKA kk A rEc[X5nURU5nUc[URRU5nUb URc [ XU5nUR U:waX6lXdUR 'U$rL)rDrsrrerrr)rr<r=roletmp_nodes_cacherXrs rC_get_or_create_cluster_node(NodesManager._get_or_create_cluster_nodePs!$- %)))4  **..y9K"k&B&B&J)$d; &&$.*.'0;K,, -rEc UR5 0n0n/nSnSnURnSnURR5GHnUR(a URn OEUR "UR UR40UD6n XRURl[U RS55n U RR5 Sn[!U 5S:XaF[!U SSS5S:Xa.[!UR5S:XaUR U SSS'U GHn U Sn [U S5nUS :Xa UR n[#U S5nUR%X5up/nUR'X[(U5nUR+U5 U S SnUHZn[US5n[#US5nUR%X5upUR'X[,U5nUR+U5 M\ [/[#U S5[#U S5S-5HnUU;aUUU'MUUSnURUR:wdM4UR+URS URS U35 [!U5S :dMr[SSR1U535e GM UR3U5nU(dGM O U(d[S[5U535UeUR6cbUR8bUUR:c)[=UR85R?5UlOUR:R?5UlURA[CUR555 U(d0URD(a[S[!U5S[FS35eXl$X l%URM[(5SUl'URP(aXlSUl)g![a [S5ef=f![an U nSn A GM Sn A ff=f)z Initializes the nodes cache, slots cache and redis connections. :startup_nodes: Responsible for discovering other nodes in the cluster FNrz(Cluster mode is not enabled on this nodeTrmrr}rjrpz vs z on slot: rz6startup_nodes could not agree on a valid slots cache: z, zORedis Cluster cannot be connected. Please provide at least one reachable node: z9All slots are not covered after query all startup_nodes. z of z covered...)*r;rr2r^rerlr<r=rr;rrNrfr.r,rrrremap_host_portrvr{rrrjoinrirtrLrMrNr get_cacherrrrJrrrrzrrKrO)rru tmp_slots disagreementsstartup_nodes_reachable fully_coveredrrV startup_noder[ cluster_slotsrrv primary_noder<r=nodes_for_slotr replica_nodes replica_nodetarget_replica_nodertmp_slots rCrNodesManager.initializecsW   "' ''  ..557L 00$55A..$))<+<+<@FANO&&|'8'89J$01B1B?1S$TM%%002 +/'M"a' a(+A./14**+q0)5):): a #A&%#Aw #LO42:',,D<?+!11$= !#">> %%k2 $QR $1L' Q8D|A/D!%!5!5d!AJD*.*J*JG_+'#))*=>%2s47|Sa\A-=>A )'5 ! $-Q<?#==K,<,<<)00#+==/k6F6F5GzRSQT U #=1A5&;'448IIm4L3M%O'"!"?3&V!55i@M}m8p''''*9~&68  ;; 4#5#5#A""**4+=+=>HHJ "11;;=  %%d?+A+A+C&DE!"$'?&@A +$ 99'B1E  & &!0  $Y%/B     s1A#P<,4P# P<#P99P<< QQQr>cSUlURR5H0nUR(dMURR 5 M2 grL)rrr^rerXrhs rCrXNodesManager.closesA $$++-D$$$%%++-.rEcZURR5 g![a gf=frL)rPr;rrSs rCr;NodesManager.resets+   # # ) ) +   s  **r<r=cNUR(aURX45$X4$)z Remap the host and port returned from the cluster to a different internal value. Useful if the client is not connecting directly to the cluster. )r9)rr<r=s rCryNodesManager.remap_host_ports(   %%tl3 3zrE)rLrMrNrQrKrHrNrOrJr9rrrr-rrPrr2r)FNNr)rrrrrr rr rtrrrrr"rPrvrr]r6rrzrIrirrrlrvrrXr;ryrrArErCrIrIys'# ",PT*..29=6:) %S/):E#s(O)K LM)'){+) 56)#?3)V *%%N#_ V ! $ *0*0X  + $ &H%T. CsuS#XrErIc^\rSrSrSrSS\S4U4SjjjrSSjrSrSr S r S r S r S r SS jrSrSrSrSrSrU=r$)riz Wrapper for PubSub class. IMPORTANT: before using ClusterPubSub, read about the known limitations with pubsub in Cluster mode and learn how to workaround them: https://redis-py-cluster.readthedocs.io/en/stable/pubsub.html r:r"c h>SUlURXX45 URcSO$URUR5RnXl0UlUR 5UlUc[5UlOX`l[T U]("SUURUURS.UD6 g)a When a pubsub instance is created without specifying a node, a single node will be transparently chosen for the pubsub connection on the first command execution. The node will be determined by: 1. Hashing the channel name in the request to find its keyslot 2. Selecting a node that handles the keyslot: If read_from_replicas is set to true or load_balancing_strategy is set, a replica can be selected. :type redis_cluster: RedisCluster :type node: ClusterNode :type host: str :type port: int N)rNrBpush_handler_funcr:rA) rset_pubsub_nodersrNclusternode_pubsub_mapping_pubsubs_generatorr"rHsuperrPrB) r redis_clusterrr<r=rr:rrNrCs rCrPClusterPubSub.__init__s.  ]$=yy  33DII>NN  % #% "&"9"9";  #%4%6D "%5 "  +!))/!33    rEcUb*URXURUR5 UnOFUb'Ub$URX4S9nURXX45 UnO[ X4/5SLa [ S5eSnXPlg)a The pubsub node will be set according to the passed node, host and port When none of the node, host, or port are specified - the node is set to None and will be determined by the keyslot of the channel in the first command to be executed. RedisClusterException will be thrown if the passed node does not exist in the cluster. If host is passed without port, or vice versa, a DataError will be thrown. :type cluster: RedisCluster :type node: ClusterNode :type host: str :type port: int NrBTz6Passing a host requires passing a port, and vice versa)_raise_on_invalid_noder<r=rvanyr)r)rrrr<r= pubsub_nodes rCrClusterPubSub.set_pubsub_node;s    ' 'tyy$)) LK  $"2###9D  ' 't BK $ $ &TU UK rEcUR$)z: Get the node that is being used as the pubsub connection )rrSs rCget_pubsub_nodeClusterPubSub.get_pubsub_node\syyrEcbUbURURS9c[SUSUS35eg)zT Raise a RedisClusterException if the node is None or doesn't exist in the cluster. NrzNode r@z doesn't exist in the cluster)rvrr,)rrrr<r=s rCr$ClusterPubSub._raise_on_invalid_nodebsF <=11DII1FN'vQtf$AB OrEcURGcURc[U5S:apUSnURR U5nURR R UURRURR5nOURR5nX@l URRU5nURUlURR5UlURRUR5 URb:[ (d/URR"R%UR5 UR&R)[+URUR[,R.UR055 URnUR2"XfR4/UQ76 g)zp Execute a subscribe/unsubscribe command. Taken code from redis-py and tweak to make it work within a cluster. Nrm)rMrNrrrrrr/r6rrrsrOregister_connect_callbackrArr5_parserset_pubsub_push_handlerrHrmr r!rnrN_executern)rrPrbrvrrerMs rCrClusterPubSub.execute_commandlsn ?? "##+t9q=#1gG<<//8D<<55HH 77 <<D <<779D #'<<#D#DT#J '7'G'G$"22AACDO OO 5 5doo F%%1:K:K''??@V@VW  " " + +7OOT%9%9:??DJJ  __  j"9"9ADArEcURUR$![a@ URR UR S9nX RUR'Us$f=f)N)r)rrr_rerr)rrrs rC_get_node_pubsubClusterPubSub._get_node_pubsubsh ++DII6 6 **11"&"8"82F39 $ $TYY /M  sAA%$A%c[[UR55H/n[UR5nUR 5nUcM-Us $ grL)rrrnextr get_message)rrrmessages rC_sharded_message_generator(ClusterPubSub._sharded_message_generatorsJs43345A$112F((*G" 6 rEc#X# URR5ShvN M$N7frL)rr^rSs rCr ClusterPubSub._pubsubs_generators(//668 8 8 8s *(*cU(a'URURRXS9nOUR5nUcg[ US5S:XaUSUR ;aUR R US5 URRUSS5 URRUS5nURURRSLa%URRUR5 UR(d<UR(d+UR(dURR5 UR (dU(agU$)N)ignore_subscribe_messagesrr sunsubscriberbF)rrrrr;"pending_unsubscribe_shard_channelsrZshard_channelsr rr subscribedchannelspatternssubscribed_eventr:r)rrrrrrs rCget_sharded_message!ClusterPubSub.get_sharded_messages, ..{/?/?@LL*CMG557G ? '&/ *n <y!T%L%LL77>>wy?QR##'' (:DA||55gi6HI++DII6AAUJ,,00;}}T]]4;N;N  ! ! ' ' )  ) )-FrEcU(a[USUSS5n[RU5nURU5 UR 5HupEUR R U5nURU5nU(aUR"S0XE0D6 OURU5 URRUR5 URRURUS055 UR(dMUR(aMURR5 SUlM g)NrrmrA)rrfromkeysr?rSrrr ssubscriberrdifference_update_normalize_keysrrsethealth_check_response_counter)rrPr s_channels s_channelhandlerrrs rCrClusterPubSub.ssubscribes Qab2D]]4( &!","2"2"4 I<<11)$!^^99>>@*D',H)$%!"4 JJz7 + JJ(( 3 JJ)5 1  <>>#D rEc.[U5R$rj)rrrSs rCrClusterPipeline.__repr__.st*%%&'rEcU$rrArSs rCrTClusterPipeline.__enter__2s rEc$UR5 grjN)r;rYs rCr]ClusterPipeline.__exit__6s  rEcFUR5 g![a gf=frL)r;rrSs rCraClusterPipeline.__del__:s"  JJL   s   c,[UR5$r)rrrSs rC__len__ClusterPipeline.__len__@s4%%&&rEcg)z?Pipeline instances should always evaluate to True on Python 3+TrArSs rC__bool__ClusterPipeline.__bool__DsrEc&UR"U0UD6$)z/ Wrapper function for pipeline_execute_command )pipeline_execute_commandrs rCrClusterPipeline.execute_commandHs,,d=f==rEc vURR[X[UR555 U$)z> Appends the executed command to the pipeline's command stack )rrPipelineCommandrrrPrQs rCr(ClusterPipeline.pipeline_execute_commandNs4 !! D3t/A/A+B C  rEcUHOnURn[U[5(dM&URX2RS-UR 5 Ue g)z( Raise the first exception on the stack rmN)resultr~rannotate_exceptionpositionrP)rstackcr[s rCraise_first_error!ClusterPipeline.raise_first_errorWsEAA!Y''''::>166B rEcSR[[U55nSUSUSURS3nU4URSS-Ulg)zC Provides extra context to the exception prior to it being handled rz Command # z (z) of pipeline caused error: rrmN)rzmapr:rP)rrVnumberrTcmdmsgs rCr"ClusterPipeline.annotate_exceptionas[hhs8W-.3%'CINNSTDUCV W ).."44 rEraise_on_errorr>cURnURX!5UR5 $!UR5 f=f)z2 Execute all the commands in the current pipeline )rsend_cluster_commandsr;)rrrs rCexecuteClusterPipeline.executeks5"" --eD JJLDJJLs /AcL/Ul[5UlSUlSUlg)z Reset back to empty pipeline. FN)rrscriptswatchingexplicit_transactionrSs rCr;ClusterPipeline.resetus& u  $)!rEcU(d/$URnURUUUS9$![[4anUS:a US-nSnAO UeSnAff=fM>)a Wrapper for CLUSTERDOWN error handling. If the cluster reports it is down it is assumed that: - connection_pool was disconnected - connection_pool was reseted - refereh_table_asap set to True It will try the number of times specified by the config option "self.cluster_error_retry_attempts" which defaults to 3 unless manually configured. If it reaches the number of times, the command will raises ClusterDownException. )rallow_redirectionsrrmN)r3_send_cluster_commandsr&r()rrrrrrs rCr%ClusterPipeline.send_cluster_commandssx$I:: 22#1'93 %o6 !A%#a'NG s)A A  A  AcN>[USS9nSn0nUGH1nURRSS5nU(a(URU5(dUR U5n O40URD6UlUR1UR>5 M U(aUREU5 U$![[4ao UR5H(nUR R#UR$5 M* UR&R)5 U(aUR+5 ef=f!UR5H(nUR R#UR$5 M* f=f![@anUUlSnAGMSnAff=f)z Send a bunch of cluster commands to the redis cluster. `allow_redirections` If the pipeline should follow `ASK` & `MOVED` responses automatically. If set to false it will raise RedisClusterException. cUR$rLrrs rCr8ClusterPipeline._send_cluster_commands..sajjrE)rFTrN node_flagrrrmzToo many targets for command rc3z# UH2n[UR[R5(dM.Uv M4 g7frL)r~rrr').0rs rC 9ClusterPipeline._send_cluster_commands..0 s-  Aahh(J(JK s,; ;cUR$rLr rs rCrr5 s!**rEcUR$rLr rs rCrrZ sQZZrEr)#sortedrQr rrrrPr,rrrrsrOr(r0r^rNrrMrrr NodeCommandsrrwritereadrGrrrrr-rJr)rrrrattemptrr|rrrrrXrFrMrf node_commandsrrYrCs rCr &ClusterPipeline._send_cluster_commandss$89 A "#~t!D!$*=*=n*M*M#'#;#;N#KL#'#8#8$+9$L(3?x{S|$q(/7x@$A0022&*O !II )!%!:!:4!@J %3J%? (4"11"22"(E$  ''*cv   8!LLNM" ###*\\^!!))!,,7$    %   )&  % % * %))++""--/"--/! %w6L!))LAH #78AvvayD;;; fd+::166!9EHH !  OOAHH %9   " "5 )i,\:!&A--55allC"0**557* 557h\\^!!))!,,7$\"! AHH!s2 MAO)PA?O>P P$PP$c(U(d [S5eg)rjz4ASK & MOVED redirection not allowed in this pipelineNr,)rrs rC_fail_on_redirect!ClusterPipeline._fail_on_redirecth s!'F "rEc(UR"S/UQ76$)NEXISTS)r)rrs rCexistsClusterPipeline.existso s##H4t44rEc[S5e)rjz method eval() is not implementedrrSs rCevalClusterPipeline.evalr s#$FGGrEc[S5e)rjz!method multi() is not implementedrrSs rCmultiClusterPipeline.multiv #$GHHrEc[S5e)rjz5method immediate_execute_command() is not implementedrrs rCimmediate_execute_command)ClusterPipeline.immediate_execute_commandz s# C  rEc[S5e)rjz0method _execute_transaction() is not implementedrrs rC_execute_transaction$ClusterPipeline._execute_transaction s#$VWWrEc[S5e)rjz(method load_scripts() is not implementedrrSs rC load_scriptsClusterPipeline.load_scripts s#$NOOrEc[S5e)rjz!method watch() is not implementedrrnamess rCwatchClusterPipeline.watch r,rEc[S5e)rjz#method unwatch() is not implementedrrSs rCunwatchClusterPipeline.unwatch s#$IJJrEc[S5e)rjz4method script_load_for_pipeline() is not implementedrrs rCscript_load_for_pipeline(ClusterPipeline.script_load_for_pipeline s# B  rEc`[U5S:wa [S5eURSUS5$)z' "Delete a key specified by ``names``" rmz=deleting multiple keys is not implemented in pipeline commandDELrrr,rr7s rCdeleteClusterPipeline.delete s8 u:?'O ##E5844rEc`[U5S:wa [S5eURSUS5$)z' "Unlink a key specified by ``names``" rmz>unlinking multiple keys is not implemented in pipeline commandUNLINKrrCr7s rCunlinkClusterPipeline.unlink s8 u:?'P ##HeAh77rE)rNr3rJrErrLrBrr6rr/rrGr5rKrr2r)NNNFNrprN)T)TT)1rrrrrEr(r0r+r#r1r'r rrtrrrr7rrPrrTr]rarrrrrrrrr;rr r r$r'r*r.r1r4r9r<r?rDrHrrrs@rCrrst  ;?DH7;#(CG,-"# %%%*%#4X #67 % %-T#x--@$A %  ] 34 %!%"**?!@%'*% %N( '> 5dd3i*B>B#L>Bl\5HI XPIK 5 8 8rErr.c^U4SjnU$)z] Prints error because some pipelined commands should be blocked when running in cluster-mode c">[STS35e)Nz"ERROR: Calling pipelined function z1 is blocked when running redis in cluster mode...r)rPrrs rCinner%block_pipeline_command..inner s!#074 5  rErA)rrLs` rCblock_pipeline_commandrN s  LrE)E BGREWRITEAOFrBITOP BRPOPLPUSHrrrrCLIENTrrrrCONFIGrECHOrrrrrrMGETzMGET NONATOMICMOVEMSETzMSET NONATOMICMSETNXPFCOUNTPFMERGErPUBLISHrrrRENAMERENAMENX RPOPLPUSHrrrrz SCRIPT KILLrSCRIPTSDIFF SDIFFSTOREz SENTINEL GET MASTER ADDR BY NAMEzSENTINEL MASTERzSENTINEL MASTERSzSENTINEL MONITORzSENTINEL REMOVEzSENTINEL SENTINELSz SENTINEL SETzSENTINEL SLAVESSENTINELrSINTER SINTERSTORESLAVEOFrrrSLOWLOGSMOVESORTSUNION SUNIONSTORErrrc"\rSrSrSrSSjrSrg)ri rjNc\XlUc0nX lX0lSUlSUlSUlg)NF)rPrQrrrr)rrPrQrs rCrPPipelineCommand.__init__ s0 ?G     rE)rPrrrQrrr)rrrrrErPrrArErCrr s  rErc0\rSrSrSrSrSrSrSrSr g) ri rjc6XlX lX0l/Ulgr)rrNrMcommands)rrrNrMs rCrPNodeCommands.__init__ s,.$ rEc:URRU5 gr)rpr)rrs rCrNodeCommands.append" s QrEc*URnURnUH nSUlM URUR UVs/sHo3R PM sn55 gs snf![ [4anUH nXClM SnAgSnAff=f)z- Code borrowed from Redis so it can be fixed N)rMrprsend_packed_command pack_commandsrPr(r0)rrMrprrs rCrNodeCommands.write& s__ ==AAH    * *((()C(Q&&()CD )C.  s)A)A$  A)$A))B9B  BcURnURHBnURbMUR"XRS40UR D6UlMD g![ [4a$nURH nX2lM SnA gSnAf[a! [R"5SUlMf=f)rjNrrm) rMrprrrPrQr(r0r-sysexc_info)rrMrrs rCrNodeCommands.read< s__ A&xx1#22:vvayVAIIVAH+,(6!]]#$+!1"||~a0AH1s/A  B=0B*B=<B=)rprMrNrN) rrrrrErPrrrrrArErCrr s  ,1rEr)nrrryrMr collectionsrenumrtypingrrrrr r r redis._parsersr r redis._parsers.helpersr redis.backoffr redis.cacherrrr redis.clientrrrredis.commandsrrredis.commands.helpersrredis.connectionrrr redis.crcrr redis.eventrr r!r"redis.exceptionsr#r$r%r&r'r(r)r*r+r,r-r.r/r0r1 redis.lockr3 redis.retryr4 redis.utilsr5r6r7r8r9r:r;rtrrDrOr\rfrzrrr{rr"rrrrrr)rr7r-rIrrrNPIPELINE_BLOCKED_COMMANDSrTreplacelowerr rrrArErCrs(  #DDD2-)XX;;>/EE8 "5c?s 3  P  P   %S/4S> )*(,    'P(  M vNvNrZ &')=Z &z**8&D& ''TIIX q+Fq+hq8lq8h  #s();  FN)Gooc3'--/G OW&