rename exporter to emitter.

Author: keith-decker

util/opentelemetry-util-genai/src/opentelemetry/util/genai/api.py

@@ -23,7 +23,7 @@
 from opentelemetry.trace import get_tracer
 
 from .data import ChatGeneration, Error, Message
-from .exporters import SpanMetricEventExporter, SpanMetricExporter
+from .emitters import SpanMetricEmitter, SpanMetricEventEmitter
 from .types import LLMInvocation
 
 # TODO: Get the tool version for emitting spans, use GenAI Utils for now
@@ -32,11 +32,11 @@
 
 class TelemetryClient:
     """
-    High-level client managing GenAI invocation lifecycles and exporting
+    High-level client managing GenAI invocation lifecycles and emitting
     them as spans, metrics, and events.
     """
 
-    def __init__(self, exporter_type_full: bool = True, **kwargs):
+    def __init__(self, emitter_type_full: bool = True, **kwargs):
         tracer_provider = kwargs.get("tracer_provider")
         self._tracer = get_tracer(
             __name__,
@@ -61,14 +61,14 @@ def __init__(self, exporter_type_full: bool = True, **kwargs):
             schema_url=Schemas.V1_28_0.value,
         )
 
-        self._exporter = (
-            SpanMetricEventExporter(
+        self._emitter = (
+            SpanMetricEventEmitter(
                 tracer=self._tracer,
                 meter=self._meter,
                 event_logger=self._event_logger,
             )
-            if exporter_type_full
-            else SpanMetricExporter(tracer=self._tracer, meter=self._meter)
+            if emitter_type_full
+            else SpanMetricEmitter(tracer=self._tracer, meter=self._meter)
         )
 
         self._llm_registry: dict[UUID, LLMInvocation] = {}
@@ -89,7 +89,7 @@ def start_llm(
         )
         with self._lock:
             self._llm_registry[invocation.run_id] = invocation
-        self._exporter.init(invocation)
+        self._emitter.init(invocation)
 
     def stop_llm(
         self,
@@ -102,7 +102,7 @@ def stop_llm(
         invocation.end_time = time.time()
         invocation.chat_generations = chat_generations
         invocation.attributes.update(attributes)
-        self._exporter.export(invocation)
+        self._emitter.emit(invocation)
         return invocation
 
     def fail_llm(
@@ -112,7 +112,7 @@ def fail_llm(
             invocation = self._llm_registry.pop(run_id)
         invocation.end_time = time.time()
         invocation.attributes.update(**attributes)
-        self._exporter.error(error, invocation)
+        self._emitter.error(error, invocation)
         return invocation
 
 
@@ -121,12 +121,12 @@ def fail_llm(
 
 
 def get_telemetry_client(
-    exporter_type_full: bool = True, **kwargs
+    emitter_type_full: bool = True, **kwargs
 ) -> TelemetryClient:
     global _default_client
     if _default_client is None:
         _default_client = TelemetryClient(
-            exporter_type_full=exporter_type_full, **kwargs
+            emitter_type_full=emitter_type_full, **kwargs
         )
     return _default_client
 

util/opentelemetry-util-genai/src/opentelemetry/util/genai/exporters.py renamed to util/opentelemetry-util-genai/src/opentelemetry/util/genai/emitters.py

@@ -127,22 +127,22 @@ def _get_metric_attributes(
     return attributes
 
 
-class BaseExporter:
+class BaseEmitter:
     """
-    Abstract base for exporters mapping GenAI types -> OpenTelemetry.
+    Abstract base for emitters mapping GenAI types -> OpenTelemetry.
     """
 
     def init(self, invocation: LLMInvocation):
         raise NotImplementedError
 
-    def export(self, invocation: LLMInvocation):
+    def emit(self, invocation: LLMInvocation):
         raise NotImplementedError
 
     def error(self, error: Error, invocation: LLMInvocation):
         raise NotImplementedError
 
 
-class SpanMetricEventExporter(BaseExporter):
+class SpanMetricEventEmitter(BaseEmitter):
     """
     Emits spans, metrics and events for a full telemetry picture.
     """
@@ -202,7 +202,7 @@ def init(self, invocation: LLMInvocation):
                 )
             )
 
-    def export(self, invocation: LLMInvocation):
+    def emit(self, invocation: LLMInvocation):
         system = invocation.attributes.get("system")
         span = self._start_span(
             name=f"{system}.chat",
@@ -361,7 +361,7 @@ def error(self, error: Error, invocation: LLMInvocation):
             )
 
 
-class SpanMetricExporter(BaseExporter):
+class SpanMetricEmitter(BaseEmitter):
     """
     Emits only spans and metrics (no events).
     """
@@ -409,7 +409,7 @@ def init(self, invocation: LLMInvocation):
                 invocation.run_id
             )
 
-    def export(self, invocation: LLMInvocation):
+    def emit(self, invocation: LLMInvocation):
         system = invocation.attributes.get("system")
         span = self._start_span(
             name=f"{system}.chat",

util/opentelemetry-util-genai/src/opentelemetry/util/genai/evals.py

@@ -1,7 +1,7 @@
 from opentelemetry.metrics import Histogram, Meter
 from opentelemetry.semconv._incubating.metrics import gen_ai_metrics
 
-# TODO: should this be in sdk or passed to the telemetry client?
+# TODO: should this be in utils or passed to the telemetry client?
 _GEN_AI_CLIENT_OPERATION_DURATION_BUCKETS = [
     0.01,
     0.02,
@@ -19,7 +19,7 @@
     81.92,
 ]
 
-# TODO: should this be in sdk or passed to the telemetry client?
+# TODO: should this be in utils or passed to the telemetry client?
 _GEN_AI_CLIENT_TOKEN_USAGE_BUCKETS = [
     1,
     4,