File: //var/opt/nydus/ops/mysql/opentelemetry/sdk/util/__pycache__/__init__.cpython-39.pyc
a
�,�h� � @ s� d dl Z d dlZd dlmZmZ d dlmZmZ d dlm Z d dl
m
Z
dd� Z dd � Z G d
d � d e�Z
e
d d
�G dd� de��ZdS )� N)� OrderedDict�deque)�MutableMapping�Sequence)�Optional)�
deprecatedc C s t j �| d �}|�d�S )z*Get an ISO 8601 string from time_ns value.g e��Az%Y-%m-%dT%H:%M:%S.%fZ)�datetime�utcfromtimestamp�strftime)� nanoseconds�ts� r
�X/opt/nydus/tmp/pip-target-wkfpz8uv/lib64/python/mysql/opentelemetry/sdk/util/__init__.py�
ns_to_iso_str s r c C s t ttdd� | �� ���S )z*Converts a dict to be used as a unique keyc S s& t | d t�r"| d t| d �fS | S )N� r )�
isinstance�list�tuple)�kvr
r
r �<lambda>$ � z!get_dict_as_key.<locals>.<lambda>)r �sorted�map�items)�labelsr
r
r �get_dict_as_key s ���r c @ s^ e Zd ZdZee d�dd�Zdd� Zdd� Zd d
� Z d d � Z
d
d� Z dd� Z e
dd� �ZdS )� BoundedListz�An append only list with a fixed max size.
Calls to `append` and `extend` will drop the oldest elements if there is
not enough room.
��maxlenc C s d| _ t|d�| _t�� | _d S )Nr r )�droppedr �_dq� threading�Lock�_lock��selfr r
r
r �__init__2 s zBoundedList.__init__c C s& t | �j� dt| j�� d| jj� d�S �N�(z , maxlen=�))�type�__name__r r r �r% r
r
r �__repr__7 s zBoundedList.__repr__c C s
| j | S �N)r )r% �indexr
r
r � __getitem__: s zBoundedList.__getitem__c C s
t | j�S r. )�lenr r, r
r
r �__len__= s zBoundedList.__len__c C s8 | j � tt| j��W d � S 1 s*0 Y d S r. )r# �iterr r r, r
r
r �__iter__@ s zBoundedList.__iter__c C sb | j �H | jjd ur4t| j�| jjkr4| jd7 _| j�|� W d � n1 sT0 Y d S )Nr )r# r r r1 r �append)r% �itemr
r
r r5 D s zBoundedList.appendc C sr | j �X | jjd urDt|�t| j� | jj }|dkrD| j|7 _| j�|� W d � n1 sd0 Y d S �Nr )r# r r r1 r �extend)r% �seqZto_dropr
r
r r8 J s zBoundedList.extendc C s t |�}| |�}|�|� |S r. )r r8 )�clsr r9 Z bounded_listr
r
r �from_seqR s
zBoundedList.from_seqN)r+ �
__module__� __qualname__�__doc__r �intr& r- r0 r2 r4 r5 r8 � classmethodr; r
r
r
r r + s r z1.4.0)�versionc @ s^ e Zd ZdZee d�dd�Zdd� Zdd� Zd d
� Z d d � Z
d
d� Z dd� Z e
dd� �ZdS )� BoundedDictz�An ordered dict with a fixed max capacity.
Oldest elements are dropped when the dict is full and a new element is
added.
r c C sD |d ur"t |t�st�|dk r"t�|| _d| _t� | _t�� | _ d S r7 )
r r? �
ValueErrorr r r �_dictr! r" r# r$ r
r
r r& b s
zBoundedDict.__init__c C s$ t | �j� dt| j�� d| j� d�S r' )r* r+ �dictrD r r, r
r
r r- m s zBoundedDict.__repr__c C s
| j | S r. �rD �r% �keyr
r
r r0 p s zBoundedDict.__getitem__c C s� | j �� | jd ur:| jdkr:| jd7 _W d � d S || jv rN| j|= n>| jd ur�t| j�| jkr�| jtt| j�� ��= | jd7 _|| j|< W d � n1 s�0 Y d S )Nr r )r# r r rD r1 �nextr3 �keys)r% rH �valuer
r
r � __setitem__s s
zBoundedDict.__setitem__c C s | j |= d S r. rF rG r
r
r � __delitem__� s zBoundedDict.__delitem__c C s8 | j � t| j�� �W d � S 1 s*0 Y d S r. )r# r3 rD �copyr, r
r
r r4 � s zBoundedDict.__iter__c C s
t | j�S r. )r1 rD r, r
r
r r2 � s zBoundedDict.__len__c C s. t |�}| |�}|�� D ]\}}|||< q|S r. )r r )r: r �mappingZ bounded_dictrH rK r
r
r �from_map� s
zBoundedDict.from_mapN)r+ r< r= r> r r? r& r- r0 rL rM r4 r2 r@ rP r
r
r
r rB Z s
rB )r r! � collectionsr r �collections.abcr r �typingr r r r r rB r
r
r
r �<module> s /