File: //var/opt/nydus/ops/mysql/opentelemetry/sdk/metrics/_internal/__pycache__/instrument.cpython-39.pyc
a
�,�hf � @ st d dl mZ d dlmZmZmZmZmZmZ d dl Z
d dl m Z m
ZmZmZmZmZmZ d dlmZ d dlm Z d dl m Z ee �Z dZ!G d d
� d
�Z"G d d � d �Z#G d
d� de"e�Z
G dd� de"e�ZG dd� de#e�ZG dd� de#e�ZG dd� de"e�ZG dd� de#e�ZG dd� de
�Z$G dd � d e�Z%G d d � d e�Z&G d d � d e�Z'G d!d"� d"e�Z(G d#d$� d$e�Z)dS )%� )� getLogger)�Dict� Generator�Iterable�List�Optional�UnionN)� CallbackT�Counter� Histogram�ObservableCounter�ObservableGauge�ObservableUpDownCounter�
UpDownCounter)�CallbackOptions)� Measurement)�InstrumentationScopez@Expected ASCII string of maximum length 63 characters but got {}c s, e Zd Zdeedeed�� fdd�
Z� ZS )� _Synchronous� �3mysql.opentelemetry.sdk.metrics.MeasurementConsumer)�name�instrumentation_scope�measurement_consumer�unit� descriptionc s� | � |||�}|d d u r(tt�|���|d d u rBtt�|���|d }|d }|d }|�� | _|| _|| _|| _|| _ t
� j |||d� d S )Nr r r �r r ) � _check_name_unit_description� Exception�_ERROR_MESSAGE�format�lowerr r r r �_measurement_consumer�super�__init__)�selfr r r r r �result�� __class__� �g/opt/nydus/tmp/pip-target-wkfpz8uv/lib64/python/mysql/opentelemetry/sdk/metrics/_internal/instrument.pyr# + s
z_Synchronous.__init__)r r )�__name__�
__module__� __qualname__�strr r# �
__classcell__r( r( r& r) r * s ��r c sJ e Zd Zd
eedeee eed�� fdd�
Ze ee
d�dd �Z � Z S ) �
_AsynchronousNr r )r r r � callbacksr r c
s� | � |||�}|d d u r(tt�|���|d d u rBtt�|���|d }|d }|d }|�� | _|| _|| _|| _|| _ t
� j ||||d� g | _ |d ur�|D ]H}t
|t�r�t|� |fttt d�dd�} | j �| � q�| j �|� q�d S )Nr r r r )�options�returnc S s( z |� | �W S ty" g Y S 0 d S �N)�send�
StopIteration)r1 �callbackr( r( r) �innern s z%_Asynchronous.__init__.<locals>.inner)r r r r r r r r r r! r" r# �
_callbacks�
isinstancer �nextr r r �append)
r$ r r r r0 r r r% r6 r7 r& r( r) r# I s4
�� z_Asynchronous.__init__)�callback_optionsr2 c c sX | j D ]L}z&||�D ]}t|j| |jd�V qW q tyP t�d| j� Y q0 qd S )N)Z
instrument�
attributesz"Callback failed for instrument %s.)r8 r �valuer= r �_logger� exceptionr )r$ r< r6 Zapi_measurementr( r( r) r6 { s
� z_Asynchronous.callback)Nr r )
r* r+ r, r- r r r r r# r r r6 r. r( r( r& r) r/ H s �
�2r/ c s> e Zd Z� fdd�Zdeeef eeef d�dd�Z � Z
S )r
c s | t u rtd��t� �| �S )Nz)Counter must be instantiated via a meter.)r
� TypeErrorr" �__new__��cls�args�kwargsr& r( r) rB � s zCounter.__new__N��amountr= c C s2 |dk rt �d| j� d S | j�t|| |�� d S )Nr z.Add amount must be non-negative on Counter %s.�r? �warningr r! �consume_measurementr �r$ rH r= r( r( r) �add� s
�z Counter.add)N� r* r+ r, rB r �int�floatr r- rM r. r( r( r& r) r
� s r
c s> e Zd Z� fdd�Zdeeef eeef d�dd�Z � Z
S )r c s | t u rtd��t� �| �S )Nz/UpDownCounter must be instantiated via a meter.)r rA r" rB rC r& r( r) rB � s zUpDownCounter.__new__NrG c C s | j �t|| |�� d S r3 )r! rK r rL r( r( r) rM � s
�zUpDownCounter.add)NrN r( r( r& r) r � s r c s e Zd Z� fdd�Z� ZS )r c s | t u rtd��t� �| �S )Nz3ObservableCounter must be instantiated via a meter.)r rA r" rB rC r& r( r) rB � s zObservableCounter.__new__�r* r+ r, rB r. r( r( r& r) r � s r c s e Zd Z� fdd�Z� ZS )r c s | t u rtd��t� �| �S )Nz9ObservableUpDownCounter must be instantiated via a meter.)r rA r" rB rC r& r( r) rB � s z ObservableUpDownCounter.__new__rQ r( r( r& r) r � s r c s> e Zd Z� fdd�Zdeeef eeef d�dd�Z � Z
S )r c s | t u rtd��t� �| �S )Nz+Histogram must be instantiated via a meter.)r rA r" rB rC r& r( r) rB � s zHistogram.__new__NrG c C s2 |dk rt �d| j� d S | j�t|| |�� d S )Nr z3Record amount must be non-negative on Histogram %s.rI rL r( r( r) �record� s �
�zHistogram.record)N) r* r+ r, rB r rO rP r r- rR r. r( r( r& r) r � s r c s e Zd Z� fdd�Z� ZS )r
c s | t u rtd��t� �| �S )Nz1ObservableGauge must be instantiated via a meter.)r
rA r" rB rC r& r( r) rB � s zObservableGauge.__new__rQ r( r( r& r) r
� s r
c @ s e Zd ZdS )�_CounterN�r* r+ r, r( r( r( r) rS � s rS c @ s e Zd ZdS )�_UpDownCounterNrT r( r( r( r) rU � s rU c @ s e Zd ZdS )�_ObservableCounterNrT r( r( r( r) rV � s rV c @ s e Zd ZdS )�_ObservableUpDownCounterNrT r( r( r( r) rW � s rW c @ s e Zd ZdS )�
_HistogramNrT r( r( r( r) rX � s rX c @ s e Zd ZdS )�_ObservableGaugeNrT r( r( r( r) rY � s rY )*�loggingr �typingr r r r r r Z mysql.opentelemetry.sdk.metricsZmysqlZmysql.opentelemetry.metricsr r
Z
APICounterr Z APIHistogramr ZAPIObservableCounterr
ZAPIObservableGauger ZAPIObservableUpDownCounterr ZAPIUpDownCounterZ0mysql.opentelemetry.metrics._internal.instrumentr Z5mysql.opentelemetry.sdk.metrics._internal.measurementr Z,mysql.opentelemetry.sdk.util.instrumentationr r* r? r r r/ rS rU rV rW rX rY r( r( r( r) �<module> s, $ @