ng\j9_RSrSSKrSSKrSSKJr SSKJrJrJrJ r \(aSSK J r SSK J r SSKJr SSKJr SS KJrJrJrJrJrJrJrJrJr SS KJrJr SS KJ r J!r! \RD"\#5r$SS K%J&r& S r'"SS\5r,"SS5r-g!\(a Sr'Sr)Sr*Sr&Sr+N(f=f)z OpenTelemetry metrics collector for redis-py. This module defines and manages all metric instruments according to OTel semantic conventions for database clients. N)Enum) TYPE_CHECKINGCallableOptionalUnion)ConnectionPool) AsyncDatabase)ConnectionPoolInterface) SyncDatabase) $REDIS_CLIENT_CONNECTION_CLOSE_REASON$REDIS_CLIENT_CONNECTION_NOTIFICATIONAttributeBuilderConnectionState CSCReason CSCResultGeoFailoverReasonPubSubDirection get_pool_name) MetricGroup OTelConfig)deprecated_argsdeprecated_function)MeterTFc$\rSrSrSrSrSrSrSrg) CloseReason0a Enum representing the reason why a Redis client connection was closed. Values: APPLICATION_CLOSE: The connection was closed intentionally by the application (for example, during normal shutdown or explicit cleanup). ERROR: The connection was closed due to an unexpected error (for example, network failure or protocol error). HEALTHCHECK_FAILED: The connection was closed because a health check or liveness check for the connection failed. application_closeerrorhealthcheck_failedN) __name__ __module__ __qualname____firstlineno____doc__APPLICATION_CLOSEERRORHEALTHCHECK_FAILED__static_attributes__r V/home/edenadmin/noVNC/venv/lib/python3.13/site-packages/redis/observability/metrics.pyrr0s , E-r*rc\rSrSrSrSrSrS\S\4Sjr SQS jr SQS jr SQS jr SQS jr SQSjrSQSjrSQSjrSRS\\S\\S\\S\\S\\S\\S\\4SjjrS\S\S\S\S\4 SjrS\SS\SS\4SjrSSS \S!\S"\SS 4S#jjr\"S$S%S&9S'\SS 4S(j5rS'\SS 4S)jr S \SS 4S*jr!S+\S,S-\"SS 4S.jr#S \S-\"SS 4S/jr$\%"S0/S1S2S39STS4\S-\"S\\S\\S5\\S0\\S\\S\\S\\S\\S6\\SS 4S7jj5r&SUS8\\'S\\SS 4S9jjr(S:\S\S;\SS 4S<jr)S \SS 4S=jr*SUS>\+S?\\S@\\SS 4SAjjr,\%"SB/SCS2S39SVSD\"SE\\SF\\SB\\SS 4 SGjj5r-SWSH\\.SS 4SIjjr/SWSJ\S\\0SS 4SKjjr1SL\SS 4SMjr2\3S\"4SNj5r4S\4SOjr5SPr6g )XRedisMetricsCollectorBaP Collects and records OpenTelemetry metrics for Redis operations. This class manages all metric instruments and provides methods to record various Redis operations including connection pool events, command execution, and cluster-specific operations. Args: meter: OpenTelemetry Meter instance config: OTel configuration object zredis-pyz1.0.0meterconfigc[(d [S5eXlX l[ 5Ul[ RURR;aUR5 [ RURR;aUR5 [ RURR;aUR5 [ RURR;aUR5 [ R URR;aUR#5 [ R$URR;aUR'5 [ R(URR;aUR+5 [,R/S5 g)NzROpenTelemetry API is not installed. Install it with: pip install opentelemetry-apiz!RedisMetricsCollector initialized)OTEL_AVAILABLE ImportErrorr/r0r attr_builderr RESILIENCY metric_groups_init_resiliency_metricsCOMMAND_init_command_metricsCONNECTION_BASIC_init_connection_basic_metricsCONNECTION_ADVANCED!_init_connection_advanced_metricsPUBSUB_init_pubsub_metrics STREAMING_init_streaming_metricsCSC_init_csc_metricsloggerinfo)selfr/r0s r+__init__RedisMetricsCollector.__init__Rs:~A    ,.  ! !T[[%>%> >  ) ) +   $++";"; ;  & & (  ' '4;;+D+D D  / / 1  * *dkk.G.G G  2 2 4   !:!: :  % % '  DKK$=$= =  ( ( * ??dkk77 7  " " $ 78r*returnNcURRSSSS9UlURRSSSS9UlURRSS S S9Ulg ) zInitialize resiliency metrics.zredis.client.errorsz{error}z`A counter of all errors (both returned to the user and handled internally in the client library)nameunit descriptionz&redis.client.maintenance.notificationsz{notification}z,Tracks server-side maintenance notificationsz"redis.client.geofailover.failoversz {geofailover}z6Total count of failovers happened using MultiDbClient.N)r/create_counter client_errorsmaintenance_notifications geo_failoversrFs r+r7.RedisMetricsCollector._init_resiliency_metricsvsv!ZZ66&z7  *.)B)B9!F*C* & "ZZ665 P7 r*c<URRSSSURRS9UlURR SSSS9UlURRS S S S9UlS Ul URR S SSS9Ul g )z$Initialize basic connection metrics.z db.client.connection.create_timeszTime to create a new connectionrLrMrN#explicit_bucket_boundaries_advisoryz'redis.client.connection.relaxed_timeoutz {relaxation}z@Counts up for relaxed timeout, counts down for unrelaxed timeoutrKzredis.client.connection.handoffz {handoff}zIConnections that have been handed off (e.g., after a MOVING notification)Nzdb.client.connection.count {connection}z4Number of connections currently in the pool by state) r/create_histogramr0buckets_connection_create_timeconnection_create_timecreate_up_down_counterconnection_relaxed_timeoutrOconnection_handoffconnection_countconnection_count_updownrSs r+r;4RedisMetricsCollector._init_connection_basic_metricss&*jj&A&A3904 0Z0Z 'B' #+/***K*K:Z+L+ ' #'**";";2c#<# !%(,zz'H'H-N(I( $r*cURRSSSS9UlURRSSSURR S9UlURRS S S S9Ulg ) z'Initialize advanced connection metrics.zdb.client.connection.timeoutsz {timeout}zaThe number of connection timeouts that have occurred trying to obtain a connection from the pool.rKzdb.client.connection.wait_timerVz/Time to obtain an open connection from the poolrWzredis.client.connection.closedrYz"Total number of closed connectionsN)r/rOconnection_timeoutsrZr0buckets_connection_wait_timeconnection_wait_timeconnection_closedrSs r+r=7RedisMetricsCollector._init_connection_advanced_metricss#'::#<#<0{$=$  %)JJ$?$?1I04 0X0X %@% !"&!:!:1<";" r*cnURRSSSURRS9Ulg)z0Initialize command execution metric instruments.zdb.client.operation.durationrVzCommand execution durationrWN)r/rZr0buckets_operation_durationoperation_durationrSs r+r9+RedisMetricsCollector._init_command_metricss4"&**"="=/404 0V0V #># r*cDURRSSSS9Ulg)z%Initialize PubSub metric instruments.zredis.client.pubsub.messagesz {message}z&Tracks published and received messagesrKN)r/rOpubsub_messagesrSs r+r?*RedisMetricsCollector._init_pubsub_metricss'#zz88/@ 9 r*cnURRSSSURRS9Ulg)z(Initialize Streaming metric instruments.zredis.client.stream.lagrVzkEnd-to-end lag per message, showing how stale are the messages when the application starts processing them.rWN)r/rZr0"buckets_stream_processing_duration stream_lagrSs r+rA-RedisMetricsCollector._init_streaming_metricss6**55*F04 0^0^ 6 r*cURRSSSS9UlURRSSSS9UlURRSS S S9Ulg ) z8Initialize Client Side Caching (CSC) metric instruments.zredis.client.csc.requestsz {request}z)The total number of requests to the cacherKzredis.client.csc.evictionsz {eviction}z#The total number of cache evictionszredis.client.csc.network_savedByz,The total number of bytes saved by using CSCN)r/rO csc_requests csc_evictionscsc_network_savedrSs r+rC'RedisMetricsCollector._init_csc_metricssu JJ55,C6  "ZZ66-=7  "&!:!:1F";" r*server_address server_portnetwork_peer_addressnetwork_peer_port error_typeretry_attempts is_internalc6[US5(dgURRUUS9nURURR UUUS95 URURR UUS95 UR RSUS9 g)a? Record error count Args: server_address: Server address server_port: Server port network_peer_address: Network peer address network_peer_port: Network peer port error_type: Error type retry_attempts: Retry attempts is_internal: Whether the error is internal (e.g., timeout, network error) rPNrzr{)r|r}r)r~r attributes)hasattrr4build_base_attributesupdatebuild_operation_attributesbuild_error_attributesrPadd) rFrzr{r|r}r~rrattrss r+record_error_count(RedisMetricsCollector.record_error_counts,t_-- !!77)#8      8 8%9"3- 9       4 4%' 5   qU3r*maint_notificationc[US5(dgURRUUS9nURURR UUS95 XV[ 'UR RSUS9 g)z Record maintenance notification count Args: server_address: Server address server_port: Server port network_peer_address: Network peer address network_peer_port: Network peer port maint_notification: Maintenance notification rQNr)r|r}rr)rr4rrrr rQr)rFrzr{r|r}rrs r+record_maint_notification_count5RedisMetricsCollector.record_maint_notification_counts$t899 !!77)#8      8 8%9"3 9  7I23 &&**1*?r* fail_from)r r fail_toreasonc[US5(dgURRUUUS9nURR SUS9$)z Record geo failover Args: fail_from: Database failed from fail_to: Database failed to reason: Reason for the failover rRN)rrrrr)rr4build_geo_failover_attributesrRr)rFrrrrs r+record_geo_failover)RedisMetricsCollector.record_geo_failoverCsWt_-- !!??@  !!%%aE%::r* pool_nameconnection_statecounterc[US5(dgURRUUS9nURR X4S9 g)z Record a connection count change for a single state. Args: pool_name: Connection pool name connection_state: State to update (IDLE or USED) counter: Number to add (positive) or subtract (negative) raN)rrr)rr4build_connection_attributesrar)rFrrrrs r+record_connection_count-RedisMetricsCollector.record_connection_count]sOt677 !!==->  $$(((Cr*z{Connection count is now tracked via record_connection_count(). This functionality will be removed in the next major versionz7.4.0)rversioncallbackc[RURR;agURR SSSU/S9Ulg)z Initialize observable gauge for connection count metric. Args: callback: Callback function to retrieve connection counts Nz%db.client.connection.count.deprecatedrYzThe number of connections that are currently in state described by the state attribute (deprecated - use db.client.connection.count instead)rLrMrN callbacks)rr:r0r6r/create_observable_gauger`rFrs r+init_connection_count+RedisMetricsCollector.init_connection_counttsO  ' 't{{/H/H H  !% B B8ej !C! r*c[RURR;aUR(dgUR R SSSU/S9Ulg)zv Initialize observable gauge for CSC items metric. Args: callback: Callback function to retrieve CSC items count Nzredis.client.csc.itemsz{item}z5The total number of cached responses currently storedr)rrBr0r6 csc_itemsr/rrs r+init_csc_items$RedisMetricsCollector.init_csc_itemssL ??$++";"; ;DNN ;;)Oj < r*c[US5(dgURRUS9nURR SUS9 g)zO Record a connection timeout event. Args: pool_name: Connection pool name rdNrrr)rr4rrdrrFrrs r+record_connection_timeout/RedisMetricsCollector.record_connection_timeoutsGt233 !!== =R   $$Q5$9r*connection_pool)r rduration_secondsc[US5(dgURR[U5S9nURR X#S9 g)z Record time taken to create a new connection. Args: connection_pool: Connection pool implementation duration_seconds: Creation time in seconds r\Nrr)rr4rrr\record)rFrrrs r+record_connection_create_time3RedisMetricsCollector.record_connection_create_timesRt566 !!==#O4>  ##**+;*Nr*c[US5(dgURRUS9nURR X#S9 g)z Record time taken to obtain a connection from the pool. Args: pool_name: Connection pool name duration_seconds: Wait time in seconds rfNrr)rr4rrfr)rFrrrs r+record_connection_wait_time1RedisMetricsCollector.record_connection_wait_timesFt344 !!== =R !!(()9(Lr* batch_sizezXThe batch_size argument is no longer used and will be removed in the next major version.z7.2.1) args_to_warnrr command_name db_namespace is_blockingc z[US5(dgURRU5(dgURR UUUS9n U R URR UUU U U S95 U R URRUS95 URRX,S9 g)aP Record command execution duration. Args: command_name: Redis command name (e.g., 'GET', 'SET', 'MULTI') duration_seconds: Execution time in seconds server_address: Redis server address server_port: Redis server port db_namespace: Redis database index batch_size: Number of commands in batch (for pipelines/transactions) error_type: Error type if operation failed network_peer_address: Resolved peer address network_peer_port: Peer port number retry_attempts: Number of retry attempts made is_blocking: Whether the operation is a blocking command rkN)rzr{r)rr|r}rrr~r) rr0should_track_commandr4rrrrrkr) rFrrrzr{rrr~r|r}rrrs r+record_operation_duration/RedisMetricsCollector.record_operation_durationsFt122 {{// == !!77)#%8      8 8)%9"3-' 9       4 4% 5  &&'7&Jr* close_reasonc[US5(dgURR5nU(aURU['UR URR US95 URRSUS9 g)z Record a connection closed event. Args: close_reason: Reason for closing (e.g. 'error', 'application_close') error_type: Error type if closed due to error rgNrrr) rr4rvaluer rrrgr)rFrr~rs r+record_connection_closed.RedisMetricsCollector.record_connection_closedst011 !!==? :F:L:LE6 7    4 4% 5  ""1"7r*connection_namerelaxedc[US5(dgURRUS9nX$['URR U(aSOSUS9 g)z Record a connection timeout relaxation event. Args: connection_name: Connection name maint_notification: Maintenance notification type relaxed: True to count up (relaxed), False to count down (unrelaxed) r^Nrrr)rr4rr r^r)rFrrrrs r+!record_connection_relaxed_timeout7RedisMetricsCollector.record_connection_relaxed_timeout7sTt9:: !!===X6H23 ''++AbU+Sr*c[US5(dgURRUS9nURR SUS9 g)zq Record a connection handoff event (e.g., after MOVING notification). Args: pool_name: Connection pool name r_Nrrr)rr4rr_rrs r+record_connection_handoff/RedisMetricsCollector.record_connection_handoffLsGt122 !!== =R ##A%#8r* directionchannelshardedc[US5(dgURRUUUS9nURR SUS9 g)z Record a PubSub message (published or received). Args: direction: Message direction ('publish' or 'receive') channel: Pub/Sub channel name sharded: True if sharded Pub/Sub channel rnN)rrrrr)rr4build_pubsub_message_attributesrnr)rFrrrrs r+record_pubsub_message+RedisMetricsCollector.record_pubsub_message^sUt.// !!AAB    u 5r* consumer_namez[The consumer_name argument is no longer used and will be removed in the next major version. lag_seconds stream_nameconsumer_groupc[US5(dgURRUUS9nURR XS9 g)z Record the lag of a streaming message. Args: lag_seconds: Lag in seconds stream_name: Stream name consumer_group: Consumer group name consumer_name: Consumer name rrN)rrr)rr4build_streaming_attributesrrr)rFrrrrrs r+record_streaming_lag*RedisMetricsCollector.record_streaming_lagxsL*t\** !!<<#)=  {=r*resultc[US5(dgURRUS9nURR SUS9 g)z] Record a Client Side Caching (CSC) request. Args: result: CSC result ('hit' or 'miss') rvN)rrr)rr4build_csc_attributesrvr)rFrrs r+record_csc_request(RedisMetricsCollector.record_csc_requestsFt^,, !!66f6E aE2r*countc[US5(dgURRUS9nURR XS9 g)zt Record a Client Side Caching (CSC) eviction. Args: count: Number of evictions reason: Reason for eviction rwN)rr)rr4rrwr)rFrrrs r+record_csc_eviction)RedisMetricsCollector.record_csc_evictionsDt_-- !!66f6E u7r* bytes_savedc[US5(dgURR5nURR XS9 g)zt Record the number of bytes saved by using Client Side Caching (CSC). Args: bytes_saved: Number of bytes saved rxNr)rr4rrxr)rFrrs r+record_csc_network_saved.RedisMetricsCollector.record_csc_network_saveds@t011 !!668 "";"Ar*c,[R"5$)z_ Get monotonic time for duration measurements. Returns: Current monotonic time in seconds )time monotonicr r*r+monotonic_time$RedisMetricsCollector.monotonic_times~~r*c<SURSURS3$)NzRedisMetricsCollector(meter=z , config=))r/r0rSs r+__repr__RedisMetricsCollector.__repr__s-djj\4;;-qQQr*)r4rPr0rgr`rar\r_r^rdrfrwrrxrvrRrQr/rkrnrr)rIN)NNNNNNN)r) NNNNNNNNN)NN)NNN)N)7r!r"r#r$r% METER_NAME METER_VERSIONrrrGr7r;r=r9r?rArCrstrint Exceptionboolrrrrrrrrrrrrfloatrrrrrrrrrrrrrrrr staticmethodrrr)r r*r+r-r-Bs JM"9e"9Z"9H (  D *    0)-%).2+/*.(,&*,4  ,4c],4'sm ,4 $C= ,4 Y' ,4! ,4d^,4\"@"@"@" "@  "@  "@H;89;67;" ;< DD*D D  D.G       0    ( :3 :4 :OJKO O  O(MM M  M("^i)-%)&*$(*..2+/(,&*;K;K ;K! ;K c] ;K sm ;KSM;KY';K'sm;K$C=;K! ;Kd^;K ;K  ;K~/3*.8{+8Y'8  86TT T T  T*99 9*"&"& 6"6#6$ 6  64%&l&*(,'+ >>c]>! >  } >  >  >:'+3#3 3&'+88#8  8$BB B$ E  R#Rr*r-).r%loggingrenumrtypingrrrrredis.asyncio.connectionrredis.asyncio.multidb.databaser redis.connectionr redis.multidb.databaser redis.observability.attributesr r rrrrrrrredis.observability.configrr redis.utilsrr getLoggerr!rDopentelemetry.metricsrr2r3Counter Histogram UpDownCounterrr-r r*r+rs ;;7<83   ?<   8 $ +N.$.$U RU R5NGI EM s5BB&%B&