ng\je5SrSSKJr SSKJrJrJrJrJr SSK r \(aSSK J r SSK J r SSKJr SSKJr S rS rS rS rS rSrSrSrSrSrSrSrSrSrSr Sr!Sr"Sr#Sr$Sr%Sr&Sr'Sr(S r)S!r*S"r+S#r,S$r-S%r.S&r/S'r0"S(S)\5r1"S*S+\5r2"S,S-\5r3"S.S/\5r4"S0S1\5r5"S2S35r6S4\S5S6\74S7jr8S8\S94S:jr9g);a OpenTelemetry semantic convention attributes for Redis. This module provides constants and helper functions for building OTel attributes according to the semantic conventions for database clients. Reference: https://opentelemetry.io/docs/specs/semconv/database/redis/ )Enum) TYPE_CHECKINGAnyDictOptionalUnionN)ConnectionPool) AsyncDatabase)ConnectionPoolInterface) SyncDatabasez db.systemz db.namespacezdb.operation.namezdb.response.status_codezdb.stored_procedure.namez error.typeznetwork.peer.addressznetwork.peer.portzserver.addressz server.portzdb.client.connection.pool.namezdb.client.connection.statezdb.client.connection.namezdb.client.geofailover.fail_fromzdb.client.geofailover.fail_tozdb.client.geofailover.reasonzredis.client.libraryzredis.client.connection.pubsubz$redis.client.connection.close.reasonz$redis.client.connection.notificationz%redis.client.operation.retry_attemptszredis.client.operation.blockingz%redis.client.pubsub.message.directionzredis.client.pubsub.channelzredis.client.pubsub.shardedzredis.client.errors.internalzredis.client.errors.categoryzredis.client.stream.namezredis.client.consumer_groupzredis.client.csc.resultzredis.client.csc.reasonc\rSrSrSrSrSrg)ConnectionStateCidleusedN)__name__ __module__ __qualname____firstlineno__IDLEUSED__static_attributes__rY/home/edenadmin/noVNC/venv/lib/python3.13/site-packages/redis/observability/attributes.pyrrCs D Drrc\rSrSrSrSrSrg)PubSubDirectionHpublishreceiverN)rrrrPUBLISHRECEIVErrrrrrHs GGrrc\rSrSrSrSrSrg) CSCResultMhitmissrN)rrrrHITMISSrrrrr$r$Ms C Drr$c\rSrSrSrSrSrg) CSCReasonRfull invalidationrN)rrrrFULL INVALIDATIONrrrrr+r+Rs D!Lrr+c\rSrSrSrSrSrg)GeoFailoverReasonW automaticmanualrN)rrrr AUTOMATICMANUALrrrrr2r2Ws I Frr2c\rSrSrSr\S*S\\S\\S\\S\ \\ 44Sjj5r \S+S \\ \\ 4S \\S \\S \\S \\S\\S\\S\ \\ 44Sjj5r\S,S\\S\\S\\S\\S\ \\ 44 Sjj5r\S-S\\S\\S\ \\ 44Sjj5r\S-S\S\\S\\S\ \\ 44Sjj5r\S*S\\S\\S\\S\ \\ 44S jj5r\S*S\\S!\\S"\\S\ \\ 44S#jj5r\S$\ S%S&\ S%S"\S\ \\ 44S'j5r\S.S\S\S\S\4S(jj5rS)rg)/AttributeBuilder\zQ Helper class to build OTel semantic convention attributes for Redis operations. Nserver_address server_port db_namespacereturnc[S[S[R30nUbX['UbX[ 'Ub[ U5U['U$)z Build base attributes common to all Redis operations. Args: server_address: Redis server address (FQDN or IP) server_port: Redis server port db_namespace: Redis database index Returns: Dictionary of base attributes redisz redis-py:v) DB_SYSTEMREDIS_CLIENT_LIBRARYr@ __version__SERVER_ADDRESS SERVER_PORTstr DB_NAMESPACE)r;r<r=attrss rbuild_base_attributes&AttributeBuilder.build_base_attributesas[$ w Ju/@/@.A"B!   %$2. !  "!,+   #"%l"3E,  r command_name batch_sizenetwork_peer_addressnetwork_peer_portstored_procedure_nameretry_attempts is_blockingc0nUb<[U[5(aURSSS9nUR5U['UbX'[ 'UbX7[ 'UbXG['UbUS:aXW['UbXg['U$)a Build attributes for a Redis operation (command execution). Args: command_name: Redis command name (e.g., 'GET', 'SET', 'MULTI'), can be str or bytes batch_size: Number of commands in batch (for pipelines/transactions) network_peer_address: Resolved peer address network_peer_port: Peer port number stored_procedure_name: Lua script name or SHA1 digest retry_attempts: Number of retry attempts made is_blocking: Whether the operation is a blocking command Returns: Dictionary of operation attributes zutf-8replace)errorsr) isinstancebytesdecodeupperDB_OPERATION_NAMENETWORK_PEER_ADDRESSNETWORK_PEER_PORTDB_STORED_PROCEDURE_NAME%REDIS_CLIENT_OPERATION_RETRY_ATTEMPTSREDIS_CLIENT_OPERATION_BLOCKING)rKrLrMrNrOrPrQrHs rbuild_operation_attributes+AttributeBuilder.build_operation_attributess2!#  #,..+22792M '3'9'9';E# $  +*>& '  ('8# $ ,.C* +  %.1*<;I7 8  "5@1 2 r pool_nameconnection_stateconnection_name is_pubsubc[R5nUbX['UbURU['UbX4[ 'UbX$[ 'U$)a1 Build attributes for connection pool metrics. Args: pool_name: Unique connection pool name connection_state: Connection state ('idle' or 'used') is_pubsub: Whether this is a PubSub connection connection_name: Unique connection name Returns: Dictionary of connection pool attributes )r9rIDB_CLIENT_CONNECTION_POOL_NAMEvalueDB_CLIENT_CONNECTION_STATEREDIS_CLIENT_CONNECTION_PUBSUBDB_CLIENT_CONNECTION_NAME)rarbrcrdrHs rbuild_connection_attributes,AttributeBuilder.build_connection_attributess[&!1 F F H  4=0 1  '0@0F0FE, -  4=0 1  &/>+ , r error_type is_internalc`0nUbURRU['[US5(a!URbURU[ 'O SU[ '[US5(a+UR bUR RU['O SU['UbX['U$)z Build error attributes. Args: is_internal: Whether the error is internal (e.g., timeout, network error) error_type: The exception that occurred Returns: Dictionary of error attributes status_codeerrorrmother) __class__r ERROR_TYPEhasattrrpDB_RESPONSE_STATUS_CODErmrgREDIS_CLIENT_ERROR_CATEGORYREDIS_CLIENT_ERROR_INTERNAL)rmrnrHs rbuild_error_attributes'AttributeBuilder.build_error_attributess!#  ! * 4 4 = =E*  M22**61;1G1G-.18-.z<00Z5J5J5V5?5J5J5P5P125<12  "1<- . r directionchannelshardedc[R5nURU['UbX['UbX#[ 'U$)z Build attributes for a PubSub message. Args: direction: Message direction ('publish' or 'receive') channel: Pub/Sub channel name sharded: True if sharded Pub/Sub channel Returns: Dictionary of PubSub message attributes )r9rIrg%REDIS_CLIENT_PUBSUB_MESSAGE_DIRECTIONREDIS_CLIENT_PUBSUB_CHANNELREDIS_CLIENT_PUBSUB_SHARDED)r{r|r}rHs rbuild_pubsub_message_attributes0AttributeBuilder.build_pubsub_message_attributessD"!1 F F H7@34  18- .  18- . r stream_nameconsumer_group consumer_namecZ[R5nUbX['UbX['U$)z Build attributes for a streaming operation. Args: stream_name: Name of the stream consumer_group: Name of the consumer group consumer_name: Name of the consumer Returns: Dictionary of streaming attributes )r9rIREDIS_CLIENT_STREAM_NAMEREDIS_CLIENT_CONSUMER_GROUP)rrrrHs rbuild_streaming_attributes+AttributeBuilder.build_streaming_attributess5"!1 F F H  ".9* +  %1?- . rresultreasonc[R5nUbX['UbURU['UbURU[ 'U$)a Build attributes for a Client Side Caching (CSC) operation. Args: pool_name: Connection pool name (used only for csc_items metric) result: CSC result ('hit' or 'miss') reason: Reason for CSC eviction ('full' or 'invalidation') Returns: Dictionary of CSC attributes )r9rIrfrgREDIS_CLIENT_CSC_RESULTREDIS_CLIENT_CSC_REASON)rarrrHs rbuild_csc_attributes%AttributeBuilder.build_csc_attributes4sP"!1 F F H  4=0 1  -3\\E) *  -3\\E) * r fail_fromr r fail_toc[R5n[U5U['[U5U['UR U[ 'U$)z Build attributes for a geo failover. Args: fail_from: Database failed from fail_to: Database failed to reason: Reason for the failover Returns: Dictionary of geo failover attributes )r9rI get_db_nameDB_CLIENT_GEOFAILOVER_FAIL_FROMDB_CLIENT_GEOFAILOVER_FAIL_TOrgDB_CLIENT_GEOFAILOVER_REASON)rrrrHs rbuild_geo_failover_attributes.AttributeBuilder.build_geo_failover_attributesRsF"!1 F F H1  c3h  D*.&*#Y'#d^# c3h##J"&"&"#$ c3h 6%)(,'+c]   } c3h 4#'&*&*C=## c3h :8967" c3h 0@@@@ @@rr9pool)r r r>cURRSS5nURRSS5n[USS5nU(a USUSU3$USU3$) a Get a short string representation of a connection pool for observability. This provides a concise pool identifier suitable for use as a metric attribute, in the format: host:port_uniqueID (matching go-redis format) Args: pool: Connection pool instance Returns: Short pool name in format "host:port_uniqueID" Example: >>> pool = ConnectionPool(host='localhost', port=6379, db=0) >>> get_pool_name(pool) 'localhost:6379_a1b2c3d4' hostunknownporti_pool_idr_)connection_kwargsgetgetattr)rrrpool_ids r get_pool_namerso$  ! ! % %fi 8D  ! ! % %fd 3DdJ+Gqay))qrdatabasercURR5SnURR5SnURnUSUSU3$)z Get a short string representation of a database for observability. Args: database: Database instance Returns: Short database name in format "{host}:{port}/{weight}" rrrr)clientget_connection_kwargsweight)rrrrs rrrsR ?? 0 0 26 :D ?? 0 0 26 :D __FV1TF!F8 $$r):renumrtypingrrrrrr@redis.asyncio.connectionr redis.asyncio.multidb.databaser redis.connectionr redis.multidb.databaser rArGrYrvr\rtrZr[rDrErfrhrjrrrrBri$REDIS_CLIENT_CONNECTION_CLOSE_REASON$REDIS_CLIENT_CONNECTION_NOTIFICATIONr]r^rrrrxrwrrrrrrr$r+r2r9rFrrrrrrsb<< 7<83   '35 .'" "B97#D ?=.!A'M$'M$(O%"C(O%;;<<5;33d d  ""  `@`@F  IJ s <%% ?@%r