refactor: rename emitters to generators and update method names for clarity

Author: keith-decker

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

@@ -296,24 +296,24 @@ def _record_duration(
         duration_histogram.record(elapsed, attributes=metric_attributes)
 
 
-class BaseEmitter:
+class BaseTelemetryGenerator:
     """
     Abstract base for emitters mapping GenAI types -> OpenTelemetry.
     """
 
-    def init(self, invocation: LLMInvocation) -> None:
+    def start(self, invocation: LLMInvocation) -> None:
         raise NotImplementedError
 
-    def emit(self, invocation: LLMInvocation) -> None:
+    def finish(self, invocation: LLMInvocation) -> None:
         raise NotImplementedError
 
     def error(self, error: Error, invocation: LLMInvocation) -> None:
         raise NotImplementedError
 
 
-class SpanMetricEventEmitter(BaseEmitter):
+class SpanMetricEventGenerator(BaseTelemetryGenerator):
     """
-    Emits spans, metrics and events for a full telemetry picture.
+    Generates spans, metrics and events for a full telemetry picture.
     """
 
     def __init__(
@@ -358,7 +358,7 @@ def _end_span(self, run_id: UUID):
                 child_state.span.end()
         state.span.end()
 
-    def init(self, invocation: LLMInvocation):
+    def start(self, invocation: LLMInvocation):
         if (
             invocation.parent_run_id is not None
             and invocation.parent_run_id in self.spans
@@ -378,7 +378,7 @@ def init(self, invocation: LLMInvocation):
             if log and self._logger:
                 self._logger.emit(log)
 
-    def emit(self, invocation: LLMInvocation):
+    def finish(self, invocation: LLMInvocation):
         system = invocation.attributes.get("system")
         span = self._start_span(
             name=f"{system}.chat",
@@ -496,9 +496,9 @@ def error(self, error: Error, invocation: LLMInvocation):
                 )
 
 
-class SpanMetricEmitter(BaseEmitter):
+class SpanMetricGenerator(BaseTelemetryGenerator):
     """
-    Emits only spans and metrics (no events).
+    Generates only spans and metrics (no events).
     """
 
     def __init__(
@@ -541,7 +541,7 @@ def _end_span(self, run_id: UUID):
                 child_state.span.end()
         state.span.end()
 
-    def init(self, invocation: LLMInvocation):
+    def start(self, invocation: LLMInvocation):
         if (
             invocation.parent_run_id is not None
             and invocation.parent_run_id in self.spans
@@ -550,7 +550,7 @@ def init(self, invocation: LLMInvocation):
                 invocation.run_id
             )
 
-    def emit(self, invocation: LLMInvocation):
+    def finish(self, invocation: LLMInvocation):
         system = invocation.attributes.get("system")
         span = self._start_span(
             name=f"{system}.chat",

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

@@ -46,7 +46,7 @@
 from opentelemetry.trace import get_tracer
 
 from .data import ChatGeneration, Error, Message
-from .emitters import SpanMetricEmitter, SpanMetricEventEmitter
+from .generators import SpanMetricEventGenerator, SpanMetricGenerator
 from .types import LLMInvocation
 
 # TODO: Get the tool version for emitting spans, use GenAI Utils for now
@@ -92,15 +92,15 @@ def __init__(self, emitter_type_full: bool = True, **kwargs: Any):
             schema_url=Schemas.V1_36_0.value,
         )
 
-        self._emitter = (
-            SpanMetricEventEmitter(
+        self._generator = (
+            SpanMetricEventGenerator(
                 tracer=self._tracer,
                 meter=self._meter,
                 logger=self._logger,
                 capture_content=self._should_collect_content(),
             )
             if emitter_type_full
-            else SpanMetricEmitter(
+            else SpanMetricGenerator(
                 tracer=self._tracer,
                 meter=self._meter,
                 capture_content=self._should_collect_content(),
@@ -129,7 +129,7 @@ def start_llm(
         )
         with self._lock:
             self._llm_registry[invocation.run_id] = invocation
-        self._emitter.init(invocation)
+        self._generator.start(invocation)
 
     def stop_llm(
         self,
@@ -142,7 +142,7 @@ def stop_llm(
         invocation.end_time = time.time()
         invocation.chat_generations = chat_generations
         invocation.attributes.update(attributes)
-        self._emitter.emit(invocation)
+        self._generator.finish(invocation)
         return invocation
 
     def fail_llm(
@@ -152,13 +152,10 @@ def fail_llm(
             invocation = self._llm_registry.pop(run_id)
         invocation.end_time = time.time()
         invocation.attributes.update(**attributes)
-        self._emitter.error(error, invocation)
+        self._generator.error(error, invocation)
         return invocation
 
 
-# Singleton accessor (avoid global statement by storing on function attribute)
-
-
 def get_telemetry_handler(
     emitter_type_full: bool = True, **kwargs: Any
 ) -> TelemetryHandler: