o
    i                     @   sr   d dl mZ d dlmZ d dlm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	eedZ
dS )   )BufferedEncoder)MSGPACK_ENCODERS)AgentlessTraceJSONEncoderc                   @   s"   e Zd ZdZdZdefddZdS )WriterClientBasezVA class encapsulating an endpoint/encoder pair that a TraceWriter can send payloads to encoderc                 C   s
   || _ d S )N)r   )selfr    r	   Y/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/internal/writer/writer_client.py__init__   s   
zWriterClientBase.__init__N)__name__
__module____qualname____doc__ENDPOINTr   r   r	   r	   r	   r
   r      s    r   c                           e Zd ZdZ fddZ  ZS )AgentWriterClientV5zv0.5/tracesc                        t t| td ||d d S )Nv0.5max_sizemax_item_size)superr   r   r   r   buffer_sizemax_payload_size	__class__r	   r
   r         
zAgentWriterClientV5.__init__r   r   r   r   r   __classcell__r	   r	   r   r
   r          r   c                       r   )AgentWriterClientV4zv0.4/tracesc                    r   )Nv0.4r   )r   r"   r   r   r   r   r	   r
   r   !   r   zAgentWriterClientV4.__init__r   r	   r	   r   r
   r"      r!   r"   c                       s2   e Zd ZdZdZdededdf fddZ  ZS )	AgentlessWriterClientzKClient for the agentless JSON span intake (EvP / public-trace-http-intake).zv1/inputr   r   returnNc                    s   t t| t||d d S )Nr   )r   r$   r   r   r   r   r	   r
   r   /   s   

zAgentlessWriterClient.__init__)r   r   r   r   r   intr   r    r	   r	   r   r
   r$   *   s    "r$   )r#   r   N)	_encodingr   encodingr   r   objectr   r   r"   r$   WRITER_CLIENTSr	   r	   r	   r
   <module>   s    
