o zEvictionPolicyInterface.cachecCr1r&r)r(valuerrrr2Cr3returncCr1r&rr+rrrtypeHr3zEvictionPolicyInterface.typecCr1r&rr+rrr evict_nextMz"EvictionPolicyInterface.evict_nextcountcCr1r&rr(r9rrr evict_manyQr8z"EvictionPolicyInterface.evict_manyr#NcCr1r&rr(r#rrrtouchUr8zEvictionPolicyInterface.touch)rrrpropertyrr2setterrr6rr7intrr;r=rrrrr0=s   r0c@sbeZdZeddZedefddZeddZededefd d Z ed e defd d Z dS)CacheConfigurationInterfacecCr1r&rr+rrrget_cache_class[r8z+CacheConfigurationInterface.get_cache_classr5cCr1r&rr+rrr get_max_size_r8z(CacheConfigurationInterface.get_max_sizecCr1r&rr+rrrget_eviction_policycr8z/CacheConfigurationInterface.get_eviction_policyr9cCr1r&rr:rrris_exceeds_max_sizegr8z/CacheConfigurationInterface.is_exceeds_max_sizercCr1r&rr(rrrris_allowed_to_cachekr8z/CacheConfigurationInterface.is_allowed_to_cacheN) rrrrrBr@rCrDboolrErrGrrrrrAZs  rAc@seZdZeedefddZeedefddZeede fddZ eede fdd Z ed e deed ffd d ZededefddZedee deefddZedeedeefddZede fddZed e defddZd S)CacheInterfacer5cCr1r&rr+rrr collectionqr3zCacheInterface.collectioncCr1r&rr+rrrconfigvr3zCacheInterface.configcCr1r&rr+rrreviction_policy{r3zCacheInterface.eviction_policycCr1r&rr+rrrsizer3zCacheInterface.sizekeyNcCr1r&rr(rNrrrgetr8zCacheInterface.getentrycCr1r&rr(rQrrrsetr8zCacheInterface.set cache_keyscCr1r&rr(rTrrrdelete_by_cache_keysr8z#CacheInterface.delete_by_cache_keysrcCr1r&rr(rrrrdelete_by_redis_keysr8z#CacheInterface.delete_by_redis_keyscCr1r&rr+rrrflushr8zCacheInterface.flushcCr1r&rrOrrr is_cachabler8zCacheInterface.is_cachable)rrrr>rrrJrArKr0rLr@rMrr r"rPrHrSrrVr/rXrYrZrrrrrIps2rIc@seZdZdeddfddZedefddZedefdd Zede fd d Z ede fd d Z de defddZdedee dffddZdeedeefddZdeeeeefdeefddZde fddZdedefddZdS) DefaultCache cache_configr5NcCs*t|_||_|j|_||j_dSr&)r_cache _cache_configrDr4_eviction_policyr2r(r\rrrr)s zDefaultCache.__init__cC|jSr&r]r+rrrrJzDefaultCache.collectioncCrar&)r^r+rrrrKrczDefaultCache.configcCrar&r_r+rrrrLrczDefaultCache.eviction_policycCs t|jSr&)lenr]r+rrrrM zDefaultCache.sizerQcCs.||jsdS||j|j<|j|jdS)NFT)rZr#r]r_r=rRrrrrSs  zDefaultCache.setrNcCs*|j|d}|dur dS|j||Sr&)r]rPr_r=)r(rNrQrrrrPs  zDefaultCache.getrTcCsBg}|D]}||dur|j||dq|dq|S)NTF)rPr]popappend)r(rTresponserNrrrrVs   z!DefaultCache.delete_by_cache_keysrc sg}g}|D]G}|g}t|tr||dnt|tr2z ||dWn ty1Ynw|jD]tfdd|DrL||dq5q|D]}|j |qP|S)Nzutf-8c3s|]}|jvVqdSr&)r).0 candidater#rr sz4DefaultCache.delete_by_redis_keys..T) isinstancerrhencoder/decodeUnicodeDecodeErrorr]anyrg)r(rrikeys_to_delete redis_key candidatesrNrrlrrXs*      z!DefaultCache.delete_by_redis_keyscCst|j}|j|Sr&)rer]clear)r( elem_countrrrrYs  zDefaultCache.flushcCs|j|jSr&)r^rGrrOrrrrZszDefaultCache.is_cachable)rrrrAr)r>rrJrKr0rLr@rMr"rHrSrr rPrrVr/rrXrYrZrrrrr[s0      r[c@seZdZdZdefddZedefddZede fdd Z ede fd d Z ede fd d ZdedeedffddZdedefddZdeedeefddZdeedeefddZde fddZdedefddZdS) CacheProxyzY Proxy object that wraps cache implementations to enable additional logic on top r2cC ||_dSr&rbr(r2rrrr) zCacheProxy.__init__r5cC|jjSr&)r]rJr+rrrrJzCacheProxy.collectioncCr|r&)r]rKr+rrrrKr}zCacheProxy.configcCr|r&)r]rLr+rrrrL r}zCacheProxy.eviction_policycCr|r&)r]rMr+rrrrMr}zCacheProxy.sizerNNcC |j|Sr&)r]rPrOrrrrP zCacheProxy.getrQcCsB|j|}|j|jrddlm}|dtjd|j |S)Nr)record_csc_eviction)r9reason) r]rSrKrErMredis.observability.recorderrr FULLrLr7)r(rQis_setrrrrrSs   zCacheProxy.setrTcCr~r&)r]rVrUrrrrV$rzCacheProxy.delete_by_cache_keysrcCr~r&)r]rXrWrrrrX'rzCacheProxy.delete_by_redis_keyscCs |jSr&)r]rYr+rrrrY*r{zCacheProxy.flushcCr~r&)r]rZrOrrrrZ-rzCacheProxy.is_cachable)rrrrrIr)r>rrJrArKr0rLr@rMrr r"rPrHrSrrVr/rXrYrZrrrrrxs"rxc@seZdZddZeddZejdefddZedefdd Z de fd d Z d e de e fd dZde ddfddZddZdS) LRUPolicycCs d|_dSr&)r2r+rrrr)2r{zLRUPolicy.__init__cCrar&rbr+rrrr25rczLRUPolicy.cacher2cCryr&rbrzrrrr29rfr5cCstjSr&)rrr+rrrr6=rczLRUPolicy.typecCs ||jjjdd}|dS)NFlastr) _assert_cacher]rJpopitem)r( popped_entryrrrr7AszLRUPolicy.evict_nextr9cCsT||t|jjkrtdg}t|D]}|jjjdd}||dq|S)Nz#Evictions count is above cache sizeFrr)rrer]rJ ValueErrorrangerrh)r(r9 popped_keys_rrrrr;Fs zLRUPolicy.evict_manyr#NcCs4||jj|durtd|jj|dS)Nz(Given entry does not belong to the cache)rr]rJrPr move_to_endr<rrrr=SszLRUPolicy.touchcCs"|jdus t|jtstddS)Nz6Eviction policy should be associated with valid cache.)r2rnrIrr+rrrr[szLRUPolicy._assert_cache)rrrr)r>r2r?rIrr6rr7r@rr;r=rrrrrr1s  rc@seZdZeZdS)EvictionPolicyN)rrrrLRUrrrrr`src@seZdZeZejZdZgdZ eeefde de defddZ dd Z d e fd d Zd efd dZde d efddZded efddZdS) CacheConfigi')JBITCOUNT BITFIELD_ROBITPOSEXISTSGEODISTGEOHASHGEOPOSGEORADIUSBYMEMBER_RO GEORADIUS_RO GEOSEARCHGETGETBITGETRANGEHEXISTSHGETHGETALLHKEYSHLENHMGETHSTRLENHVALSz JSON.ARRINDEXz JSON.ARRLENzJSON.GETz JSON.MGETz JSON.OBJKEYSz JSON.OBJLENz JSON.RESPz JSON.STRLENz JSON.TYPELCSLINDEXLLENLPOSLRANGEMGETSCARDSDIFFSINTER SINTERCARD SISMEMBERSMEMBERS SMISMEMBERSORT_ROSTRLENSUBSTRSUNIONzTS.GETzTS.INFOzTS.RANGEz TS.REVRANGETYPEXLENXPENDINGXRANGEXREAD XREVRANGEZCARDZCOUNTZDIFFZINTER ZINTERCARD ZLEXCOUNTZMSCOREZRANGE ZRANGEBYLEX ZRANGEBYSCOREZRANK ZREVRANGEZREVRANGEBYLEXZREVRANGEBYSCOREZREVRANKZSCOREZUNIONmax_size cache_classrLcCs||_||_||_dSr&) _cache_class _max_sizer_)r(rrrLrrrr)s zCacheConfig.__init__cCrar&)rr+rrrrBzCacheConfig.get_cache_classr5cCrar&rr+rrrrCrzCacheConfig.get_max_sizecCrar&rdr+rrrrDrzCacheConfig.get_eviction_policyr9cCs ||jkSr&rr:rrrrEr{zCacheConfig.is_exceeds_max_sizercCs ||jvSr&)DEFAULT_ALLOW_LISTrFrrrrGr{zCacheConfig.is_allowed_to_cacheN)rrrr[DEFAULT_CACHE_CLASSrrDEFAULT_EVICTION_POLICYDEFAULT_MAX_SIZErr@rr)rBrCrDrHrErrGrrrrrds(O  rc@seZdZedefddZdS)CacheFactoryInterfacer5cCr1r&rr+rrr get_cacher8zCacheFactoryInterface.get_cacheN)rrrrrIrrrrrrsrc@s.eZdZddeefddZdefddZdS) CacheFactoryNr\cCs ||_|jdurt|_dSdSr&)_configrr`rrrr)s  zCacheFactory.__init__r5cCs|j}t||jdS)N)r\)rrBrx)r(rrrrrs zCacheFactory.get_cacher&)rrrr rr)rIrrrrrrsrN)abcrr collectionsr dataclassesrenumrtypingrrr r redis.observability.attributesr r rrr"r0rArIr[rxrrrrrrrrrs*    .\7/l