File: //var/opt/nydus/ops/primordial/log/__pycache__/envelopedata.cpython-39.pyc
a
�,�h� � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlmZ d dlm Z e�
e �Z G dd� de�Z
G dd� de�ZG d d
� d
e�ZG d d � d e�ZG d
d� de�ZG dd� de�ZG dd� de�ZdS )� )�OptionalN)�LogData)�IPc sR e Zd ZdZdZdZdZdZeeeefZdZ dZ
dZ d Z d
d �� fd d
� Z
� ZS )�
ConfigLogDatazUStore configuration log data for passing to other logging classes and easy retrieval.�typeZsub_typeZ
datacenter� environmentZhfsZvhfs�localZLOCALN��returnc sN t � �� | �| j| j� | �| j| j� | �| j| j� | �| j | j
� d S �N) �super�__init__�set�
TYPE_FIELD� DEFAULT_TYPE�SUB_TYPE_FIELD�DEFAULT_SUB_TYPE�DATACENTER_FIELD�DEFAULT_DATACENTER�ENVIRONMENT_FIELD�DEFAULT_ENVIRONMENT��self�� __class__� �L/opt/nydus/tmp/pip-target-wkfpz8uv/lib/python/primordial/log/envelopedata.pyr
s
zConfigLogData.__init__)�__name__�
__module__� __qualname__�__doc__r r r r �FIELDSr r r r r
�
__classcell__r r r r r s r c sT e Zd ZdZdZdZefZd
eej dd�� fdd�
Z
ej dd�� fdd � Z � Z S ) �PayloadLogDatazBExtract and store payload log data for parsing and easy retrieval.z1.0.0�linenoN��recordr
c s d| _ t� �|� d S )NT)Z
freefieldsr r
�r r& r r r r
* s zPayloadLogData.__init__c
s� t � �|� | �d|�� � | �d|j� | �dd � | �d|j� | �d|j� | �d|j� | �| j|j � | �d| j
� |j r�|j \}}}| �dd � t
�|||��� d S )
N�msg�pathname�
class_name�module�filename� func_name�versionZstrace� )r �loadr �
getMessager) r+ r, �funcName� LINENO_FIELDr$ �DATA_SCHEMA_VERSION�exc_info�join� traceback�format_exception)r r& �exc_type� exc_value�
exc_tracebackr r r r0 . s
�zPayloadLogData.load)N)
r r r r r4 r3 �
RAW_FIELDSr �logging� LogRecordr
r0 r" r r r r r# $ s r# c s: e Zd ZdZdZdZeefZejdd�� fdd� Z � Z
S )�ServiceLogDatazBExtract and store service log data for parsing and easy retrieval.�name�threadNr% c s> t � �|� | �| jt�d�p"|j� | �| jt|j �� d S )NZ SYSLOG_IDENT)
r r0 r �
NAME_FIELD�os�getenv� processName� THREAD_FIELD�strrA r' r r r r0 D s zServiceLogData.load) r r r r rB rF r! r= r> r0 r" r r r r r? > s
r? c s@ e Zd ZdZdZdZdZeeefZej dd�� fdd� Z
� Z S ) � HostLogDataz?Extract and store host log data for parsing and easy retrieval.Zservice�hostname�ipNr% c sH t � �|� | �| jt�d�� | �| jt� t|�}| �| j |� d S )N�HOSTNAME)
r r0 r �HOSTNAME_FIELDrC rD �IP_FIELDr r? �
SERVICE_FIELD)r r& ZserviceLogDatar r r r0 Q s
zHostLogData.load) r r r r rN rL rM r! r= r> r0 r" r r r r rH J s
rH c sR e Zd ZdZdZdZdZdZefZeZ dd�� fdd � Z
e d�d
d �Z e Z
� ZS ) � EnvelopeRolezVStore log role (e.g. ''PERFORMANCE' ) for passing to other classes and easy retrieval.�roleZ DEVELOPMENTZ PERFORMANCEZBUSINESS_ANALYTICSNr c s t � �� | �| j| j� d S r )r r
r �
ROLE_FIELD� DEFAULT_ROLEr r r r r
d s
zEnvelopeRole.__init__c C s t | �| j��S r )rG �getrQ r r r r �__str__h s zEnvelopeRole.__str__)r r r r rQ ZROLE_DEVELOPMENTZROLE_PERFORMANCEZROLE_BUSINESS_ANALYTICSr! rR r
rG rT �__repr__r" r r r r rO Y s rO c sr e Zd ZdZdZdZdZeeefZeZdZ dZ
dZ dd�� fd d
� Z e
d�d d �ZeZee
d d
�dd��Z� ZS )�EnvelopeVersionzVStore Envelope version (e.g. '1.0.0') for passing to other classes and easy retrieval.�major�minor�patch� r Nr c s> t � �� | �| j| j� | �| j| j� | �| j| j� d S r ) r r
r � MAJOR_FIELD�
DEFAULT_MAJOR� MINOR_FIELD�
DEFAULT_MINOR� PATCH_FIELD�
DEFAULT_PATCHr r r r r
{ s
zEnvelopeVersion.__init__c s t d�� fdd�� jD ���S )N�.c s g | ]}t � �|���qS r �rG rS ��.0�fieldr r r �
<listcomp>� � z+EnvelopeVersion.__str__.<locals>.<listcomp>)rG r6 r! r r r r rT � s zEnvelopeVersion.__str__)r. r
c C sJ t t| �d��\}}}t� }|�tj|� |�tj|� |�tj|� |S )Nra )�map�int�splitrV r r[ r] r_ )r. rW rX rY ZenvelopeVersionr r r �
fromString� s zEnvelopeVersion.fromString)r r r r r[ r] r_ r! r< r\ r^ r` r
rG rT rU � staticmethodrk r" r r r r rV n s
rV c s� e Zd ZdZdZdZdZdZdZdZ eeeefZ
e
Z dZ d Z
d
Zd
Zd d �� fd
d� Zed �dd�ZeZeed d�dd��Z� ZS )�EnvelopeDataSchemazbStore Envelope data schema version (e.g. '1.0.0') for passing to other classes and easy retrieval.r@ rW rX rY ra �-�defaultrZ r Nr c sN t � �� | �| j| j� | �| j| j� | �| j| j� | �| j | j
� d S r ) r r
r rB � DEFAULT_NAMEr[ r\ r] r^ r_ r` r r r r r
� s
zEnvelopeDataSchema.__init__c sF t � j�� fdd�� j� j� jfD ���}t � j�� �� j�|g��S )Nc s g | ]}t � �|���qS r rb rc r r r rf � rg z.EnvelopeDataSchema.__str__.<locals>.<listcomp>) rG �VERSION_SEPARATORr6 r[ r] r_ �NAME_VERSION_SEPARATORrS rB )r r. r r r rT � s ��zEnvelopeDataSchema.__str__)� data_schemar
c C sp t t| �tj��\}}t t|�tj��\}}}t� }|�tj|� |�tj |� |�tj
|� |�tj |� |S r ) rh rG rj rm rr ri rq r rB r[ r] r_ )rs r@ r. rW rX rY ZenvelopeDataSchemar r r rk � s z EnvelopeDataSchema.fromString)r r r r rB r[ r] r_ rq rr r! r< rp r\ r^ r` r
rG rT rU rl rk r" r r r r rm � s$ rm )�typingr r= �logging.configrC r7 Zprimordial.log.datar Zprimordial.constantsr � getLoggerr �LOGr r# r? rH rO rV rm r r r r �<module> s
"