File: //opt/alt/python37/lib/python3.7/site-packages/xray/continuous/__pycache__/manager.cpython-37.pyc
B
�V�d�
� @ sH d Z ddlmZ ddlmZ ddlmZ ddlmZ G dd � d e�Z d
S ) zR
This module contains continuous tracing manager, aimed to enable|disable
tracing
� )�urlparse� )�ContinuousCommon� )� XRayError)� timestampc @ s� e Zd ZdZeeed�dd��Zeeedd�dd�Zedd �d
d �Zedd �d d
�Z edd �dd�Z
eedd�dd�Z dd� Z dS )�ContinuousManagerz;
enable|disable|start|stop|list continuous tracing
)�url�returnc C s4 t | �}|j�dd�}|�d�d }|j� d|� �S )zW
Leaves only domain path of URL, without www. prefix and :port postfix
zwww.� �:r z://)r �netloc�replace�split�scheme)r � fragmentsZ_no_www_netlocZ_no_port_netloc� r �H/opt/alt/python37/lib/python3.7/site-packages/xray/continuous/manager.py� url_sanitize s z ContinuousManager.url_sanitizeN)�domainr �emailr
c C sd || j kr,t� || �|�|ddd�| j |< n,| jjd|| j | d�d� td|� d���| �� d S )
z+
Enable continuous tracing
r �running)Z
creation_timer Z original_urlr Zexecution_count�statusz(Continuous monitoring is already enabled)r �
tracing_entry)�extrazContinuous monitoring for z is already enabledN)� tracing_confr r �logger�errorr �dump_tracing_configuration)�selfr r r r r r �enable" s
zContinuousManager.enable)r r
c C s | � |� dS )z,
Disable continuous tracing
N)Z remove_tracing_configuration)r r r r r �disable8 s zContinuousManager.disablec C s | � |d� dS )z-
Start continuous monitoring
r N)�
update_status)r r r r r �start> s zContinuousManager.startc C s | � |d� dS )z,
Stop continuous monitoring
�stoppedN)r" )r r r r r �stopD s zContinuousManager.stop)r r r
c C s� yH| j | d |krF| jjd||| j | d�d� td|� d|� ���W n< tk
r� | jjd|| j d�d� td|� d ���Y nX || j | d< | �� d
S ) z;
Set given 'status' for requested 'domain'
r z#Continuous monitoring is already %s)r r )r zContinuous monitoring for z is already z$Continuous monitoring is not enabled)r Ztracing_entriesz is not enabledN)r r r r �KeyErrorr )r r r r r r r" J s" z ContinuousManager.update_statusc C s t | j�� �S )z5
Return all continuous tracing tasks
)�listr �values)r r r r �get_tracing_lista s z"ContinuousManager.get_tracing_list)
�__name__�
__module__� __qualname__�__doc__� staticmethod�strr r r! r# r% r" r) r r r r r s r N)
r- � urllib.parser �commonr �internal.exceptionsr �internal.utilsr r r r r r �<module> s