RiR1SSKrSSKrSSKJr SSKJr SSKJrJrJ r SSK J r J r J r Jr SSKJr "SS\ 5r"S S \ 5r"S S \5r"S S\\ 5r"SS\5r"SS\5rg)N)Redis)SentinelCommands) ConnectionConnectionPool SSLConnection)ConnectionError ReadOnlyError ResponseError TimeoutError) str_if_bytesc\rSrSrSrg)MasterNotFoundError N__name__ __module__ __qualname____firstlineno____static_attributes__r`/var/www/html/backend/Backoffice_Marketplace/venv/lib/python3.13/site-packages/redis/sentinel.pyrr rrc\rSrSrSrg)SlaveNotFoundErrorrNrrrrrrrrrcV^\rSrSrU4SjrSrU4SjrSrSrS U4Sjjr Sr U=r $) SentinelManagedConnectionc R>URS5Ul[TU] "S0UD6 g)Nconnection_poolr)popr!super__init__)selfkwargs __class__s rr$"SentinelManagedConnection.__init__s%%zz*;< "6"rcURn[U5RSURS3nUR(a SURSUR 3nX#-nU$)N z,host=z,port=)r!typer service_namehostport)r%pools host_infos r__repr__"SentinelManagedConnection.__repr__s^##Dz""#9T->->,?s C 99  6$))=I Arc>UuUlUl[TU] 5 URR (a:UR S5 [UR55S:wa [S5egg)NPINGPONGz PING failed) r-r.r#connectr!check_connection send_commandr read_responser)r%addressr's r connect_to$SentinelManagedConnection.connect_to sc& 49     0 0   f %D..01V;%m44< 1rcDUR(agURR(a*URURR 55 gURR 5HnURU5s $ [e![ a M,f=fN)_sockr! is_masterr<get_master_address rotate_slavesrr)r%slaves r_connect_retry(SentinelManagedConnection._connect_retry(s ::     ) ) OOD00CCE F--;;=??511> % $'s6B BBcPURRURS5$)Ncgr?r)errors r3SentinelManagedConnection.connect..6sTr)retrycall_with_retryrE)r%s rr7!SentinelManagedConnection.connect5s zz))$*=*=?QRRrc>[TU]US9$![a8 URR(aUR 5 [ S5eef=f)N)disable_decodingz"The previous master is now a slave)r#r:r r!rA disconnectr)r%rPr's rr:'SentinelManagedConnection.read_response8sU 7(:J(K K ##-- !%&JKK  s AA)r!r-r.)F) rrrrr$r2r<rEr7r:r __classcell__r's@rrrs'#5 %S  rrc\rSrSrSrg)SentinelManagedSSLConnectionGrNrrrrrVrVGrrrVcV^\rSrSrSrU4SjrSrU4SjrU4SjrSr Sr S r U=r $) SentinelConnectionPoolKz Sentinel backed connection pool. If ``check_connection`` flag is set to True, SentinelManagedConnection sends a PING command right after establishing the connection. c L>URSURSS5(a[O[5US'URSS5UlURSS5Ul[ TU]"S0UD6 [R"U5URS'Xl X l g) Nconnection_classsslFrATr8r!r) getr"rVrrAr8r#r$weakrefproxyconnection_kwargsr,sentinel_manager)r%r,rbr&r's rr$SentinelConnectionPool.__init__Ss%+ZZ zz%'' )* & !"  K6 & +=u E "6"4;MM$4G01( 0rc|UR(aSOSn[U5RSURSUS3$)NmasterrDr*())rAr+rr,)r%roles rr2SentinelConnectionPool.__repr__as:>>xwt*%%&i0A0A/B!D6KKrc>>[TU]5 SUlSUlgr?)r#resetmaster_addressslave_rr_counter)r%r's rrkSentinelConnectionPool.resetes  " $rc>UR(+=(d8 UR=(a% URURUR4:Hn[ 5nU=(a UR U5$r?)rArlr-r.r#owns_connection)r% connectioncheckparentr's rrp&SentinelConnectionPool.owns_connectionjsZNN" NN Xt22z 6XX ;// ;;rcURRUR5nUR(a%URU:waXlUR SS9 U$)NF)inuse_connections)rbdiscover_masterr,rArlrQ)r%rls rrB)SentinelConnectionPool.get_master_addressqsO..>>t?P?PQ >>""n4&4#%8rc## URRUR5nU(aURc([R "S[ U5S- 5Ul[[ U55H5nURS-[ U5-UlXRnUv M7 UR5v [SUR<35e![a N%f=f7f)zRound-robin slave balancerrzNo slave found for ) rbdiscover_slavesr,rmrandomrandintlenrangerBrr)r%slaves_rDs rrC$SentinelConnectionPool.rotate_slaves{s&&66t7H7HI $$,(.q#f+/(J%3v;')-)>)>)Bc&k(Q%445 (  ))+ +!#6t7H7H6K!LMM#   s*B/C-2CC- C*'C-)C**C-)r8rArlrbr,rm) rrrr__doc__r$r2rkrprBrCrrSrTs@rrYrYKs. 1L% <NNrrYcf\rSrSrSrSSjrSrSrSrSr S r S r \ \ 4S jr\ \ 4S jrS rg)Sentinela Redis Sentinel cluster client >>> from redis.sentinel import Sentinel >>> sentinel = Sentinel([('localhost', 26379)], socket_timeout=0.1) >>> master = sentinel.master_for('mymaster', socket_timeout=0.1) >>> master.set('foo', 'bar') >>> slave = sentinel.slave_for('mymaster', socket_timeout=0.1) >>> slave.get('foo') b'bar' ``sentinels`` is a list of sentinel nodes. Each node is represented by a pair (hostname, port). ``min_other_sentinels`` defined a minimum number of peers for a sentinel. When querying a sentinel, if it doesn't meet this threshold, responses from that sentinel won't be considered valid. ``sentinel_kwargs`` is a dictionary of connection arguments used when connecting to sentinel instances. Any argument that can be passed to a normal Redis connection can be specified here. If ``sentinel_kwargs`` is not specified, any socket_timeout and socket_keepalive options specified in ``connection_kwargs`` will be used. ``connection_kwargs`` are keyword arguments that will be used when establishing a connection to a Redis server. Nc Uc<UR5VVs0sHupVURS5(dMXV_M! nnnX0lUVVs/sHupx[Xx40URD6PM snnUlX lX@lgs snnfs snnf)Nsocket_)items startswithsentinel_kwargsr sentinelsmin_other_sentinelsra) r%rrrrakvhostnamer.s rr$Sentinel.__init__s  "!2!8!8!:!:all9>U!:  /#, "+ ( 9D$8$8 9"+ $7 !2  sBB "B c>[URSS55nSUR5;aURS5 U(a1[R "UR 5R"U0UD6 gUR HnUR"U0UD6 M g)z Execute Sentinel command in sentinel nodes. once - If set to True, then execute the resulting command on a single node at random, rather than across the entire sentinel cluster. onceFT)boolr^keysr"r|choicerexecute_command)r%argsr&rsentinels rrSentinel.execute_commands FJJvu-. V[[] " JJv   MM$.. ) 9 94 J6 J!NN(($9&9+rc/nURH7nURSRURR55 M9 [ U5R SSRU5S3$)Nz {host}:{port}z )rappend format_mapr!rar+rjoin)r%sentinel_addressesrs rr2Sentinel.__repr__sjH  % %**8+C+C+U+UV 't*%%&l388 !K "335KK -Eu00EENN1%?q!4>>+#>T{E&M11&?"$88H"IJJ$\2  sB''B;:B;cz/nUH2nUS(d US(aMURUSUS45 M4 U$)z1Remove slaves that are in an ODOWN or SDOWN staterrrr.)r)r%r slaves_aliverDs r filter_slavesSentinel.filter_slavessF EZ E*$5   teFm < =rcURH1nURU5nUR U5nU(dM/Us $ /$![[[4a MOf=f)z;Returns a list of alive slaves for service ``service_name``)rsentinel_slavesrr r r)r%r,rrs rr{Sentinel.discover_slavesscH !11,?''/Fv ' $]LA  sAAAc rSUS'[UR5nURU5 U"U"X40UD6S9$)a Returns a redis client instance for the ``service_name`` master. A :py:class:`~redis.sentinel.SentinelConnectionPool` class is used to retrieve the master's address before establishing a new connection. NOTE: If the master's address has changed, any cached connections to the old master are closed. By default clients will be a :py:class:`~redis.Redis` instance. Specify a different class to the ``redis_class`` argument if you desire something different. The ``connection_pool_class`` specifies the connection pool to use. The :py:class:`~redis.sentinel.SentinelConnectionPool` will be used by default. All other keyword arguments are merged with any connection_kwargs passed to this class and passed to the connection pool as keyword arguments to be used to initialize Redis connections. TrAr!dictraupdater%r, redis_classconnection_pool_classr&ras r master_forSentinel.master_for sM:#{ !7!78  (1&7  rc rSUS'[UR5nURU5 U"U"X40UD6S9$)a Returns redis client instance for the ``service_name`` slave(s). A SentinelConnectionPool class is used to retrieve the slave's address before establishing a new connection. By default clients will be a :py:class:`~redis.Redis` instance. Specify a different class to the ``redis_class`` argument if you desire something different. The ``connection_pool_class`` specifies the connection pool to use. The SentinelConnectionPool will be used by default. All other keyword arguments are merged with any connection_kwargs passed to this class and passed to the connection pool as keyword arguments to be used to initialize Redis connections. FrArrrs r slave_forSentinel.slave_for3sM0${ !7!78  (1&7  r)rarrr)rN)rrrrrr$rr2rrwrr{rrYrrrrrrrrsO> 3,"TK. 4 $ R4  rr)r|r_ redis.clientrredis.commandsrredis.connectionrrrredis.exceptionsrr r r redis.utilsr rrrrVrYrrrrrsr +FFXX$ /   1 1h #