mkx
d dl mZ d dlmZ d dlmZmZ d dlmZ d dl m
Z
e
rd dl m Z e
g d Z e
g d Zd Z G d
d e Zd Zd
S ) )absolute_import)Hub)capture_internal_exceptionslogger) Integration)MYPY)Any)
decrdecrbygetincrincrbypttlsetsetexsetnxttl)deltouchunlinkc dd l } n# t $ r Y d S w xY wt | j t | d| j }d|cxk rdk rn d S t | j d S d S )Nr VERSION)r r )r r r ) rediscluster ImportErrorpatch_redis_client RedisClustergetattr __version__StrictRedisCluster)r versions }/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/sentry_sdk/integrations/redis.py_patch_redisclusterr# s |0111 lI|/GHHG 7&&&&Y&&&&&&<:;;;;; '&s
c ( e Zd ZdZed ZdS )RedisIntegrationredisc ` dd l } t | j dd l}t |j j t |j j t |j j n# t $ r Y nw xY w t d S # t $ r t j d Y d S w xY w)Nr z3Error occured while patching `rediscluster` library)
r& r StrictRedis
rb.clientsclients FanoutClient
MappingClient
RoutingClientr r# Exceptionr exception)r& rbs r"
setup_oncezRedisIntegration.setup_once( s 5,--- 9
rz 6 7 7 7 rz 7 8 8 8 rz 7 8 8 8 8 D T ! ! ! ! ! T T T R S S S S S S Ts# A* *
A76A7;B B-,B-N)__name__
__module__ __qualname__
identifier staticmethodr1 r" r% r% % s7 JT T \T T Tr8 r% c . | j fd}|| _ dS )z`
This function can be used to instrument custom redis client classes or
subclasses.
c t j }| t
| |g|R i |S |}t 5 |g}t | D ]/\ }}|dk r n#| t | 0d | }d d d n # 1 swxY w Y | d| 5 } |r|
d| |rW|rU| }
|
t v s |
t v r/t | dk r |
d|d | |g|R i |cd d d S # 1 swxY w Y d S ) N
r& )op descriptionz
redis.command z redis.keyr )r currentget_integrationr% r enumerateappendreprjoin
start_spanset_taglower_SINGLE_KEY_COMMANDS_MULTI_KEY_COMMANDSlen) selfnameargskwargshubr> description_partsiargspanname_lowold_execute_commands r" sentry_patched_execute_commandz:patch_redis_client..sentry_patched_execute_commandG s( k / 0 0 8&&tTCDCCCFCC C
(
*
* 6 6!% #D//
4
43r66E!((c3333 ((#455K 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 ^^wK^
@
@ DD
4 _d333
7
7 ::<< 444 333D QLLd1g666&&tTCDCCCFCC D D D D D D D D D D D D D D D D D Ds& AB))B-0B- A>EE EN)execute_command)clsrW rV s @r" r r > s= - D D D D D@ 9Cr8 N)
__future__r
sentry_sdkr sentry_sdk.utilsr r sentry_sdk.integrationsr sentry_sdk._typesr typingr frozensetrI rJ r# r% r r7 r8 r" ra s
& & & & & & @ @ @ @ @ @ @ @ / / / / / / " " " " " " yWWW i : : :;; < < <&T T T T T{ T T T2)9 )9 )9 )9 )9r8