keJi ddlmZmZddlmZmZddlZddlmZddlm Z ddl m Z ddl m Z Gdd eZGd d eZGd d eZe eee fZGddeeZdS))ABCabstractmethod)OptionalUnionN) RedisCluster) WeightedList)CircuitBreaker)NumberceZdZeedefdZejedefdZeedee fdZ e jedee fdZ dS) AbstractDatabasereturncdS)z]The weight of this database in compare to others. Used to determine the database failover to.Nselfs \/var/www/html/movieo_spanner_bot/venv/lib/python3.11/site-packages/redis/multidb/database.pyweightzAbstractDatabase.weight  rcdS)z5Set the weight of this database in compare to others.Nrrrs rrzAbstractDatabase.weightrrcdS)z6Health check URL associated with the current database.Nrrs rhealth_check_urlz!AbstractDatabase.health_check_urlrrrcdS)z>Set the health check URL associated with the current database.Nrrrs rrz!AbstractDatabase.health_check_urlrrN) __name__ __module__ __qualname__propertyrfloatrsetterrstrrrrrr r s     ^X  ] U   ^]  (3-   ^X  #   ^   rr ceZdZ d dedeefdZedefdZej defdZedeefdZ e j deefd Z dS) BaseDatabaseNrrc"||_||_dSN)_weight_health_check_url)rrrs r__init__zBaseDatabase.__init__&s  !1rr c|jSr&r'rs rrzBaseDatabase.weight. |rc||_dSr&r+rs rrzBaseDatabase.weight2  rc|jSr&r(rs rrzBaseDatabase.health_check_url6s %%rc||_dSr&r0rs rrzBaseDatabase.health_check_url:s!1rr&) rrrr rr"r)rrr!rrrrr$r$%s+/222#3-2222X ]U]&(3-&&&X&2#222222rr$c eZdZdZeedeeje ffdZ e j edeeje ffdZ eede fdZ e j ede fdZ d S) SyncDatabasez5Database with an underlying synchronous redis client.r cdS)zThe underlying redis client.Nrrs rclientzSyncDatabase.clientBrrr5cdS)z Set the underlying redis client.Nrrr5s rr5zSyncDatabase.clientHrrcdS)z)Circuit breaker for the current database.Nrrs rcircuitzSyncDatabase.circuitNrrr9cdS)z1Set the circuit breaker for the current database.Nrrr9s rr9zSyncDatabase.circuitTrrN)rrr__doc__rrrredisRedisrr5r!r r9rrrr3r3?s??  ek<78   ^X  ] U5; #<=   ^]     ^X  ^ ~   ^^   rr3c eZdZ d deejefdedede e ffd Z e deejeffdZ e jdeejeffd Z e defd Zejdefd ZxZS) DatabaseNr5r9rrc||_||_||j_t||dS)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_cbdatabasesuperr))rr5r9rr __class__s rr)zDatabase.__init___s>    !122222rr c|jSr&rBrs rr5zDatabase.clienttr,rc||_dSr&rHr7s rr5zDatabase.clientxr.rc|jSr&rCrs rr9zDatabase.circuit|s xrc||_dSr&rKr;s rr9zDatabase.circuits rr&)rrrrr=r>rr r rr"r)rr5r!r9 __classcell__)rFs@rr@r@^s5 +/ 33ek</03 3 3 #3- 333333*ek<78X ]U5; #<=]X ^~^rr@)abcrrtypingrrr=rredis.data_structurerredis.multidb.circuitr redis.typingr r r$r3tuple Databasesr@rrrrUsR########"""""""" ------000000     s   422222#2224     #   8 |V34 5 $$$$$|\$$$$$r