o
i| @ s d dl mZ d dlmZ d dlmZ d dlmZmZ d dl m
Z
d dl m Z m
Z
d dlmZmZ d dlmZmZmZmZ d d lmZ d d
lmZmZmZ d d l m Z m Z d d l Z G d
d de Z G dd deZ!eG dd deZ"eG dd deZ#eG dd de
Z$d S ) ) annotations)Sequence) dataclass)Anycast)context)LogDataLogRecordProcessor) LogExporterLogExportResult)AggregationTemporalityMetricExporterMetricExportResult MetricsData) Aggregation) ReadableSpanSpan
SpanProcessor) SpanExporterSpanExportResultNc @ s: e Zd ZdZdddZdd d ZddddZdddZdS )WrapperSpanExporterz:A base class for SpanExporters that wrap another exporter.exporterr returnNonec C s
|| _ d S N)wrapped_exporter)selfr r i/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/logfire/_internal/exporters/wrapper.py__init__
z WrapperSpanExporter.__init__spansSequence[ReadableSpan]r c C | j |S r r export)r r! r r r r% zWrapperSpanExporter.export0u timeout_millisintboolc C r# r r force_flushr r( r r r r, r& z WrapperSpanExporter.force_flushc C s | j d S r r shutdownr r r r r/ s z WrapperSpanExporter.shutdownN)r r r r )r! r" r r r' r( r) r r* r r )__name__
__module__ __qualname____doc__r r% r, r/ r r r r r s
r c sL e Zd ZdZ d d fd d
Zd d ddZd d!ddZd"d#dd Z ZS )$WrapperMetricExporterz r r8 " s r8 c @ sF e Zd ZU dZded< ddd d ZdddZdddZd d ddZdS ) WrapperSpanProcessor z WrapperSpanProcessor.on_startr c C s | j | d S r )rG on_end)r rH r r r rM A s zWrapperSpanProcessor.on_endc C s8 t | j W d d S 1 sw Y d S r )logfiresuppress_instrumentationrG r/ r0 r r r r/ D s
"z WrapperSpanProcessor.shutdownr' r( r) r* c C s8 t | j|W d S 1 sw Y d S r )rN rO rG r, r- r r r r, H s
$z WrapperSpanProcessor.force_flushr )rH r rI rJ r r )rH r r r r3 r1 r2 ) r4 r5 r6 r7 __annotations__rK rM r/ r, r r r r rE 8 s
rE c @ s, e Zd ZU dZded< d
dd Zd
d Zd S )WrapperLogExporterz9A base class for LogExporters that wrap another exporter.r
r batchSequence[LogData]r r c C s t t| j|S r )r r r r% )r rR r r r r% S rL zWrapperLogExporter.exportc C
| j S r )r r/ r0 r r r r/ V r zWrapperLogExporter.shutdownN)rR rS r r )r4 r5 r6 r7 rP r% r/ r r r r rQ M s
rQ c @ s8 e Zd ZU dZded< ddd Zd
d ZddddZdS )WrapperLogProcessorrF r rG log_datar r r c C r# r )rG on_emit)r rV r r r rW ` r& zWrapperLogProcessor.on_emitc C rT r )rG r/ r0 r r r r/ c r z WrapperLogProcessor.shutdownr' r( r) c C r# r )rG r, r- r r r r, f r& z WrapperLogProcessor.force_flushN)rV r r r r1 )r( r) )r4 r5 r6 r7 rP rW r/ r, r r r r rU Z s
rU )%
__future__r collections.abcr dataclassesr typingr r
opentelemetryr opentelemetry.sdk._logsr r opentelemetry.sdk._logs.exportr
r opentelemetry.sdk.metrics.exportr r
r r opentelemetry.sdk.metrics.viewr opentelemetry.sdk.tracer r r opentelemetry.sdk.trace.exportr r rN r r8 rE rQ rU r r r r s(