o <‘ði‹ã@s–ddlmZddlmZmZddlmZmZddlm Z ddl m Z ddl m Z mZddlmZGdd „d e ƒZe eeefZGd d „d eeƒZd S) é)Úabstractmethod)ÚOptionalÚUnion)ÚRedisÚ RedisCluster)Ú WeightedList)ÚCircuitBreaker)ÚAbstractDatabaseÚ BaseDatabase)ÚNumberc@s|eZdZdZeedeeeffdd„ƒƒZ e j edeeeffdd„ƒƒZ eede fdd„ƒƒZ e j ed e fd d„ƒƒZ d S) Ú AsyncDatabasez6Database with an underlying asynchronous redis client.ÚreturncCódS)zThe underlying redis client.N©©Úselfrrú]/root/parts/websockify/install/lib/python3.10/site-packages/redis/asyncio/multidb/database.pyÚclientózAsyncDatabase.clientrcCr)z Set the underlying redis client.Nr©rrrrrrrcCr)z)Circuit breaker for the current database.NrrrrrÚcircuitrzAsyncDatabase.circuitrcCr)z1Set the circuit breaker for the current database.Nr©rrrrrr rN) Ú__name__Ú __module__Ú __qualname__Ú__doc__ÚpropertyrrrrrÚsetterrrrrrrr sr c s¢eZdZ ddeeefdededee f‡fdd„ Z e deeeffd d „ƒZ e j deeeffd d „ƒZ e defd d „ƒZej defdd „ƒZdd„Z‡ZS)ÚDatabaseNrrÚweightÚhealth_check_urlcs&||_||_||j_tƒ ||¡dS©N)Ú_clientÚ_cbÚdatabaseÚsuperÚ__init__)rrrrr ©Ú __class__rrr&+szDatabase.__init__r cCó|jSr!©r"rrrrr7ózDatabase.clientcCó ||_dSr!r*rrrrr;ó cCr)r!©r#rrrrr?r+zDatabase.circuitcCr,r!r.rrrrrCr-cCsd|j›d|j›dS)NzDatabase(client=z , weight=ú))rrrrrrÚ__repr__GszDatabase.__repr__r!)rrrrrrrÚfloatrÚstrr&rrrrr0Ú __classcell__rrr'rr*s(û þýüû rN)ÚabcrÚtypingrrÚ redis.asynciorrÚredis.data_structurerÚredis.multidb.circuitrÚredis.multidb.databaser r Ú redis.typingr r ÚtupleÚ DatabasesrrrrrÚs