Ë
|
|
çúhñ ã óÊ d dl mZmZ d dlmZmZ d dlZd dlmZ d dlm Z d dl
|
m Z d dl m Z G d d e« Z G d
|
d e« Z G d d e« Ze eee f Z G d dee« Zy)é )ÚABCÚabstractmethod)ÚOptionalÚUnionN)Ú RedisCluster)Ú WeightedList)ÚCircuitBreaker)ÚNumberc óÀ e Zd Zeedefd« « Zej edefd« « Zeedee fd« « Z
|
e
|
j edee fd« « Z
|
y) ÚAbstractDatabaseÚreturnc ó y)z]The weight of this database in compare to others. Used to determine the database failover to.N© ©Úselfs õi H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/multidb/database.pyÚweightzAbstractDatabase.weight ó ð ó r c ó y)z5Set the weight of this database in compare to others.Nr ©r r s r r zAbstractDatabase.weight r r c ó y)z6Health check URL associated with the current database.Nr r s r Úhealth_check_urlz!AbstractDatabase.health_check_url r r r c ó y)z>Set the health check URL associated with the current database.Nr ©r r s r r z!AbstractDatabase.health_check_url r r N) Ú__name__Ú
|
__module__Ú __qualname__Úpropertyr Úfloatr Úsetterr Ústrr r r r r r s Ø Øð ò ó ó ð ð ]]Øð Uò ó ó ð ð Øð (¨3¡-ò ó ó ð ð × Ñ Øð °¸#± ò ó ó ñ r r c ó² e Zd Z d
|
dedee fdZedefd« Zej defd« Zedee fd« Z
|
e
|
j dee fd « Z
|
y) Ú BaseDatabaseNr r c ó || _ || _ y ©N)Ú_weightÚ_health_check_url)r r r s r Ú__init__zBaseDatabase.__init__& s ð
|
Ø!1Õ r r c ó | j S r& ©r' r s r r zBaseDatabase.weight. ó à||Ðr c ó || _ y r& r+ r s r r zBaseDatabase.weight2 ó à r c ó | j S r& ©r( r s r r z BaseDatabase.health_check_url6 s à×%Ñ%Ð%r c ó || _ y r& r0 r s r r z BaseDatabase.health_check_url: s
|
à!1Õ r r& ) r r r r r r" r) r r r! r r r r r$ r$ % s ð +/ñ2àð2ð # 3-ó2ð ð ò ó ð ð ]]ð Uò ó ð ð ð& (¨3¡-ò &ó ð&ð × Ñ ð2°¸#± ò 2ó ñ2r r$ c óô e Zd ZdZeedeej e f fd« « Z
|
e
|
j edeej e f fd« « Z
|
eede fd« « Z e j ede fd« « Z y )
|
Ú SyncDatabasez5Database with an underlying synchronous redis client.r c ó y)z The underlying redis client.Nr r s r ÚclientzSyncDatabase.clientB r r r5 c ó y)z Set the underlying redis client.Nr ©r r5 s r r5 zSyncDatabase.clientH r r c ó y)z)Circuit breaker for the current database.Nr r s r ÚcircuitzSyncDatabase.circuitN r r r9 c ó y)z1Set the circuit breaker for the current database.Nr ©r r9 s r r9 zSyncDatabase.circuitT r r N)r r r Ú__doc__r r r ÚredisÚRedisr r5 r! r r9 r r r r3 r3 ? s³ Ù?à Øð ekk¨<Ð 7Ñ8ò ó ó ð ð ]]Øð U 5§;¡;° Ð#<Ñ =ò ó ó ð ð Øð ò ó ó ð ð ^^Øð ~ò ó ó ñ r r3 c
|
ó e Zd Z d deej
|
ef dedede e
|
f fd Z e deej
|
ef fd« Z e j deej
|
ef fd« Z e defd « Zej defd
|
« Z xZS ) ÚDatabaser5 r9 r r c ód || _ || _ | | j _ t | ||« y)at
|
Initialize a new Database instance.
|
|
Args:
|
client: Underlying Redis client instance for database operations
|
circuit: Circuit breaker for handling database failures
|
weight: Weight value used for database failover prioritization
|
health_check_url: Health check URL associated with the current database
|
N)Ú_clientÚ_cbÚdatabaseÚsuperr) )r r5 r9 r r Ú __class__s r r) zDatabase.__init___ s/ ø ð ØØ ÔÜ ÑÐ!1Õ2r r c ó | j S r& ©rB r s r r5 zDatabase.clientt r, r c ó || _ y r& rH r7 s r r5 zDatabase.clientx r. r c ó | j S r& ©rC r s r r9 zDatabase.circuit| s àxxr c ó || _ y r& rK r; s r r9 zDatabase.circuit s àr r& )r r r r r= r> r r r r r" r) r r5 r! r9 Ú __classcell__)rF s @r r@ r@ ^ sÕ ø ð +/ñ 3àekk <Ð/Ñ0ð3ð ð3ð ð 3ð
|
# 3-õ 3ð* ð ekk¨<Ð 7Ñ8ò ó ð ð ]]ð U 5§;¡;° Ð#<Ñ =ò ó ð ð ð ò ó ðð ^^ð~ò ó ôr r@ )Úabcr r Útypingr r r= r Úredis.data_structurer Úredis.multidb.circuitr Ú redis.typingr
|
r r$ r3 ÚtupleÚ Databasesr@ r r r ú<module>rU sd ðß #ß "ã Ý Ý -Ý 0Ý ô sô ô42Ð#ô 2ô4 Ð#ô ð8 |¨VÐ 3Ñ4Ñ 5 ô$|\õ $r
|
