Ë
|
|
çúha% ã ó d dl mZmZ d dlmZ d dlmZ d dlmZ d dl m
|
Z
|
m Z m Z m Z G d de« Z G d d e« Z ed
|
¬ « G d d « « Z G d d« Z G d de« Z G d de« Z G d de« Z G d de« Z G d de« Z G d de« Z G d d e« Z G d d e« Z G d d!e« Zy")#é )ÚABCÚabstractmethod)Ú OrderedDict)Ú dataclass)ÚEnum)ÚAnyÚListÚOptionalÚUnionc ó e Zd ZdZdZy)ÚCacheEntryStatusÚVALIDÚ IN_PROGRESSN)Ú__name__Ú
|
__module__Ú __qualname__r r © ó õ^ H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/cache.pyr r s Ø EØ Kr r c ó e Zd ZdZdZy)ÚEvictionPolicyTypeÚ
|
time_basedÚfrequency_basedN)r r r r r r r r r r s Ø JØ'Or r T)Úfrozenc ó" e Zd ZU eed< eed< y)ÚCacheKeyÚcommandÚ
|
redis_keysN)r r r ÚstrÚ__annotations__Útupler r r r r s
à LØÔr r c ó, e Zd ZdededefdZd Zd Zy)Ú
|
CacheEntryÚ cache_keyÚ cache_valueÚstatusc ó< || _ || _ || _ || _ y ©N)r$ r% r& Úconnection_ref)Úselfr$ r% r& r) s r Ú__init__zCacheEntry.__init__ s" ð #Ø&ÔØ Ø ,Õr c óp t | j | j | j | j f« S r( )Úhashr$ r% r& r) ©r* s r Ú__hash__zCacheEntry.__hash__% s/ ÜØ ^^T× -Ñ -¨t¯{©{¸D×<OÑ<OÐ Pó
|
ð
|
r c ó0 t | « t |« k( S r( )r- )r* Úothers r Ú__eq__zCacheEntry.__eq__* s ÜDzT %[Ñ(Ð(r N) r r r r Úbytesr r+ r/ r2 r r r r# r# s- ð
|
-àð
|
-ð ð
|
-ð !ó
|
-ò
|
ó
|
)r r# c óÄ e Zd Zeed « « Zej ed « « Zeedefd« « Zede fd« Z
|
ede de e fd« Z ede dd fd
|
« Zy ) ÚEvictionPolicyInterfacec ó y r( r r. s r Úcachez EvictionPolicyInterface.cache/ ó ð r c ó y r( r )r* Úvalues r r7 z EvictionPolicyInterface.cache4 r8 r Úreturnc ó y r( r r. s r Útypez EvictionPolicyInterface.type9 r8 r c ó y r( r r. s r Ú
|
evict_nextz"EvictionPolicyInterface.evict_next> ó à r Úcountc ó y r( r ©r* rA s r Ú
|
evict_manyz"EvictionPolicyInterface.evict_manyB r@ r r$ Nc ó y r( r ©r* r$ s r Útouchz EvictionPolicyInterface.touchF r@ r )r r r Úpropertyr r7 Úsetterr r= r r? Úintr rD rG r r r r5 r5 . sÃ Ø Øñ ó ó ð ð \\Øñ ó ó ð ð Øð Ð(ò ó ó ð ð ð Hò ó ð ð ð 𠨨X©ò ó ð ð ð xð ¨Dò ó ñ r r5 c óv e Zd Zed « Zedefd« Zed « Zededefd« Z ede
|
defd« Z y )
|
ÚCacheConfigurationInterfacec ó y r( r r. s r Úget_cache_classz+CacheConfigurationInterface.get_cache_classL r@ r r; c ó y r( r r. s r Ú get_max_sizez(CacheConfigurationInterface.get_max_sizeP r@ r c ó y r( r r. s r Úget_eviction_policyz/CacheConfigurationInterface.get_eviction_policyT r@ r rA c ó y r( r rC s r Úis_exceeds_max_sizez/CacheConfigurationInterface.is_exceeds_max_sizeX r@ r r c ó y r( r ©r* r s r Úis_allowed_to_cachez/CacheConfigurationInterface.is_allowed_to_cache\ r@ r N) r r r r rN rJ rP rR ÚboolrT r rW r r r rL rL K s Øñ ó ð ð ð cò ó ð ð ñ ó ð ð ð ¨ð °ò ó ð ð ð ¨3ð °4ò ó ñ r rL c óF e Zd Zeedefd« « Zeedefd« « Zeede fd« « Z
|
eede fd« « Z ede deedf fd« Zed edefd
|
« Zed ee dee fd « Zed ee dee fd« Zede fd« Zede defd« Zy)ÚCacheInterfacer; c ó y r( r r. s r Ú
|
collectionzCacheInterface.collectionb r8 r c ó y r( r r. s r ÚconfigzCacheInterface.configg r8 r c ó y r( r r. s r Úeviction_policyz CacheInterface.eviction_policyl r8 r c ó y r( r r. s r ÚsizezCacheInterface.sizeq r8 r ÚkeyNc ó y r( r ©r* rc s r ÚgetzCacheInterface.getv r@ r Úentryc ó y r( r ©r* rg s r ÚsetzCacheInterface.setz r@ r Ú
|
cache_keysc ó y r( r )r* rk s r Údelete_by_cache_keysz#CacheInterface.delete_by_cache_keys~ r@ r r c ó y r( r )r* r s r Údelete_by_redis_keysz#CacheInterface.delete_by_redis_keys r@ r c ó y r( r r. s r ÚflushzCacheInterface.flush r@ r c ó y r( r re s r Ú is_cachablezCacheInterface.is_cachable r@ r )r r r rH r r r\ rL r^ r5 r` rJ rb r r r# rf rX rj r rm r3 ro rq rs r r r rZ rZ a sm Ø Øð Kò ó ó ð ð Øð Ð3ò ó ó ð ð Øð Ð!8ò ó ó ð ð Øð cò ó ó ð ð ð xð E¨*°dÐ*:Ñ$;ò ó ð ð ð ð ¨ò ó ð ð ð ¨t°H©~ð À$ÀtÁ*ò ó ð ð ð ¨t°E©{ð ¸tÀD¹zò ó ð ð ð sò ó ð ð ð xð ¨Dò ó ñ r rZ c óò e Zd ZdeddfdZedefd« Zedefd« Zede fd« Z
|
ede fd« Z d e defd
|
Zd edee df fd Zd ee dee fdZdee dee fdZde fdZd edefdZy)Ú DefaultCacheÚ cache_configr; Nc ó¬ t « | _ || _ | j j « j « | _ | | j
|
_ y r( )r Ú_cacheÚ _cache_configrR r: Ú_eviction_policyr7 ©r* rv s r r+ zDefaultCache.__init__ sC ô "m Ø )ÔØ $× 2Ñ 2× FÑ FÓ H× NÑ NÓ PÔ Ø&*× Ñ Õ#r c ó | j S r( ©rx r. s r r\ zDefaultCache.collection ó à{{Ðr c ó | j S r( )ry r. s r r^ zDefaultCache.config s à×!Ñ!Ð!r c ó | j S r( ©rz r. s r r` z DefaultCache.eviction_policy¡ s à×$Ñ$Ð$r c ó, t | j « S r( )Úlenrx r. s r rb zDefaultCache.size¥ s ä4;;Ó Ð r rg c óH | j |j « sy|| j |j < | j j |j « | j
|
j t | j « « r| j j « y)NFT) rs r$ rx rz rG ry rT r r? ri s r rj zDefaultCache.set© ss Ø× Ñ §¡Ô0Øà', EOOÑ$Ø × Ñ ×#Ñ# E§O¡OÔ4à × Ñ × 1Ñ 1´#°d·k±kÓ2BÔ CØ × !Ñ !× ,Ñ ,Ô .àr rc c óz | j j |d « }|y | j j |« |S r( )rx rf rz rG )r* rc rg s r rf zDefaultCache.getµ s7 Ø TÓ*à =Øà × Ñ ×#Ñ# CÔ(Ø r rk c ó¶ g }|D ]Q }| j |« -| j j |« |j d« A|j d« S |S )NTF)rf rx ÚpopÚappend)r* rk Úresponserc s r rm z!DefaultCache.delete_by_cache_keys¾ sS Øà ò 'CØxx}Ð(Ø Ô$Ø Õ%à Õ&ð 'ð r r c ó$ g }g }|D ]d }t |t « r|j « }| j D ]3 }||j v s|j |« |j d« 5 f |D ] }| j j |« |S )NT)Ú
|
isinstancer3 Údecoderx r r r )r* r r Úkeys_to_deleteÚ redis_keyr$ rc s r ro z!DefaultCache.delete_by_redis_keysÊ s ØØà#ò *IÜ)¤UÔ+Ø %× ,Ñ ,Ó . Ø ![[ò * Ø × 4Ñ 4Ò4Ø"×)Ñ)¨)Ô4Ø OO DÕ)ñ *ð *ð "ò !CØ KKOOCÕ ð !ð r c ód t | j « }| j j « |S r( )r rx Úclear)r* Ú
|
elem_counts r rq zDefaultCache.flushÛ s& ÜÓ%
|
Ø ×ÑÔØÐr c óL | j j |j « S r( )ry rW r re s r rs zDefaultCache.is_cachableà s Ø×!Ñ!×5Ñ5°c·k±kÓBÐBr )r r r rL r+ rH r r\ r^ r5 r` rJ rb r# rX rj r r rf r rm r3 ro rq rs r r r ru ru s ð+à1ð+ð
|
ó+ð ðKò ó ðð ð"Ð3ò "ó ð"ð ð%Ð!8ò %ó ð%ð ð cò ó ð ð
|
ð
|
¨ó
|
ðxð E¨*°dÐ*:Ñ$;ó ð
|
¨t°H©~ð
|
À$ÀtÁ*ó
|
ð¨t°E©{ð ¸tÀD¹zó ð"só ð
|
Cxð C¨Dô Cr ru c ó e Zd Zd Zed « Zej defd« Zedefd« Z de
|
fdZ de de e
|
fd Zd
|
e
|
dd fd Zd Zy )Ú LRUPolicyc ó d | _ y r( )r7 r. s r r+ zLRUPolicy.__init__å s Ø
|
r c ó | j S r( r} r. s r r7 zLRUPolicy.cacheè r~ r r7 c ó || _ y r( r} )r* r7 s r r7 zLRUPolicy.cacheì s à r r; c ó" t j S r( )r r r. s r r= zLRUPolicy.typeð s ä!×,Ñ,Ð,r c óx | j « | j j j d¬« }|d S )NF©Úlastr )Ú _assert_cacherx r\ Úpopitem)r* Ú popped_entrys r r? zLRUPolicy.evict_nextô s5 Ø ×ÑÔ Ø{{×-Ñ-×5Ñ5¸5Ð5ÓA ØAÐ r rA c ó | j « |t | j j « kD r t d« g }t |« D ]< }| j j j d¬« }|j |d « > |S )Nz#Evictions count is above cache sizeFr r )r r rx r\ Ú
|
ValueErrorÚranger r )r* rA Ú popped_keysÚ_r s r rD zLRUPolicy.evict_manyù s Ø ×ÑÔ Ø 3t{{×-Ñ-Ó.Ò .Ü Ð BÓCÐ Cà äu ò 0AØ ;;×1Ñ1×9Ñ9¸uÐ9ÓELØ × Ñ |¨AÕ /ð 0ð Ðr r$ Nc óÎ | j « | j j j |« t d« | j j j |« y )Nz(Given entry does not belong to the cache)r rx r\ rf r Ú move_to_endrF s r rG zLRUPolicy.touch sM Ø ×ÑÔ à ;;× !Ñ !× %Ñ % iÓ 0Ð 8Ü Ð GÓHÐ Hà × Ñ ×*Ñ*¨9Õ5r c óf | j t | j t « s t d« y )Nz6Eviction policy should be associated with valid cache.)r7 r rZ r r. s r r zLRUPolicy._assert_cache s+ Ø ::Ð ¤Z°·
|
±
|
¼NÔ%KÜ Ð UÓVÐ Vð &Lr )r r r r+ rH r7 rI rZ r r= r r? rJ r rD rG r r r r r r ä s òð ñó ðð \\ð >ò ó ð ð ð-Ð(ò -ó ð-ð Hó ð
|
𠨨X©ó ð6xð 6¨Dó 6óWr r c ó e Zd ZeZy)ÚEvictionPolicyN)r r r r ÚLRUr r r r¨ r¨ s Ø
|
Cr r¨ c ó e Zd ZeZej ZdZg d¢Z eeefde
|
de defdZ d Z de
|
fd Zdefd
|
Zd e
|
defd Zd edefdZy)Ú CacheConfigi' )JÚBITCOUNTÚ BITFIELD_ROÚBITPOSÚEXISTSÚGEODISTÚGEOHASHÚGEOPOSÚGEORADIUSBYMEMBER_ROÚ GEORADIUS_ROÚ GEOSEARCHÚGETÚGETBITÚGETRANGEÚHEXISTSÚHGETÚHGETALLÚHKEYSÚHLENÚHMGETÚHSTRLENÚHVALSz JSON.ARRINDEXz JSON.ARRLENzJSON.GETz JSON.MGETz JSON.OBJKEYSz JSON.OBJLENz JSON.RESPz JSON.STRLENz JSON.TYPEÚLCSÚLINDEXÚLLENÚLPOSÚLRANGEÚMGETÚSCARDÚSDIFFÚSINTERÚ
|
SINTERCARDÚ SISMEMBERÚSMEMBERSÚ
|
SMISMEMBERÚSORT_ROÚSTRLENÚSUBSTRÚSUNIONzTS.GETzTS.INFOzTS.RANGEz TS.REVRANGEÚTYPEÚXLENÚXPENDINGÚXRANGEÚXREADÚ XREVRANGEÚZCARDÚZCOUNTÚZDIFFÚZINTERÚ
|
ZINTERCARDÚ ZLEXCOUNTÚZMSCOREÚZRANGEÚ ZRANGEBYLEXÚ ZRANGEBYSCOREÚZRANKÚ ZREVRANGEÚZREVRANGEBYLEXÚZREVRANGEBYSCOREÚZREVRANKÚZSCOREÚZUNIONÚmax_sizeÚ cache_classr` c ó. || _ || _ || _ y r( )Ú _cache_classÚ _max_sizerz )r* ré rê r` s r r+ zCacheConfig.__init__i s ð (ÔØ!Ø /Õ r c ó | j S r( )rì r. s r rN zCacheConfig.get_cache_classs s Ø× Ñ Ð r r; c ó | j S r( ©rí r. s r rP zCacheConfig.get_max_sizev s Ø~~Ð r c ó | j S r( r r. s r rR z CacheConfig.get_eviction_policyy s Ø×$Ñ$Ð$r rA c ó || j kD S r( rð rC s r rT z CacheConfig.is_exceeds_max_size| s Øt~~Ñ%Ð%r r c ó || j v S r( )ÚDEFAULT_ALLOW_LISTrV s r rW z CacheConfig.is_allowed_to_cache s Ø$×1Ñ1Ð1Ð1r N)r r r ru ÚDEFAULT_CACHE_CLASSr¨ r© ÚDEFAULT_EVICTION_POLICYÚDEFAULT_MAX_SIZErô rJ r r+ rN rP rR rX rT r rW r r r r« r« s Ø&ÐØ ,× 0Ñ 0ÐØ ÐòKÐð^ )Ø.Ø*Añ 0àð0ð ð0ð (ó 0ò!ð có ð% ^ó %ð&¨ð &°ó &ð2¨3ð 2°4ô 2r r« c ó" e Zd Zedefd« Zy)ÚCacheFactoryInterfacer; c ó y r( r r. s r Ú get_cachez CacheFactoryInterface.get_cache r@ r N)r r r r rZ rû r r r rù rù s Øð >ò ó ñ r rù c ó, e Zd Zddee fdZdefdZy)Ú CacheFactoryNrv c óJ || _ | j t « | _ y y r( )Ú_configr« r{ s r r+ zCacheFactory.__init__ s! Ø# à <<Ð Ü&=DLð r r; c ó\ | j j « } || j ¬« S )N)rv )rÿ rN )r* rê s r rû zCacheFactory.get_cache s# Øll×2Ñ2Ó4 Ù¨¯ © Ô5Ð5r r( )r r r r
|
r« r+ rZ rû r r r rý rý s ñ) X¨kÑ%:ó )ð 6>ô 6r rý N)Úabcr r Ú collectionsr Ú dataclassesr Úenumr Útypingr r r
|
r r r r r# r5 rL rZ ru r r¨ r« rù rý r r r ú<module>r sÒ ðß #Ý #Ý !Ý ß -Ó -ô tô ô
|
(ô (ñ
|
$Ô÷ð ó ð÷
|
)ñ )ô, cô ô: #ô ô,+ Sô + ô\RC>ô RCôj,WÐ'ô ,Wô^Tô ôi2Ð-ô i2ôX Cô ô 6Ð(õ 6r
|
