is enabled

Author: Liudmila Molkova

opentelemetry-api/src/opentelemetry/_events/__init__.py

@@ -122,6 +122,14 @@ def __init__(
         self._schema_url = schema_url
         self._attributes = attributes
 
+    @abstractmethod
+    def is_enabled(
+        self,
+        severity_number: Optional[SeverityNumber] = None,
+        context: Optional[Context] = None
+    ) -> bool:
+        """Returns True if the logger is enabled for given severity and context, False otherwise."""
+
     @abstractmethod
     def emit(self, record: "LogRecord") -> None:
         """Emits a :class:`LogRecord` representing a log to the processing pipeline."""
@@ -131,12 +139,14 @@ def emit_event(
         self,
         name: str,
         timestamp: Optional[int] = None,
+        observed_timestamp: Optional[int] = None,
+        severity_number: Optional[SeverityNumber] = None,
+        severity_text: Optional[str] = None,
         context: Optional[Context] = None,
         body: Optional[Any] = None,
-        severity_number: Optional[SeverityNumber] = None,
         attributes: Optional[Attributes] = None,
     ) -> None:
-        """Emits a :class:`LogRecord` representing a event to the processing pipeline."""
+        """Emits an event to the processing pipeline."""
 
 
 class NoOpLogger(Logger):
@@ -145,6 +155,13 @@ class NoOpLogger(Logger):
     All operations are no-op.
     """
 
+    def is_enabled(
+        self,
+        severity_number: Optional[SeverityNumber] = None,
+        context: Optional[Context] = None
+    ) -> bool:
+        return False
+
     def emit(self, record: "LogRecord") -> None:
         pass
 
@@ -190,6 +207,13 @@ def _logger(self) -> Logger:
             return self._real_logger
         return self._noop_logger
 
+    def is_enabled(
+        self,
+        severity_number: Optional[SeverityNumber] = None,
+        context: Optional[Context] = None
+    ) -> bool:
+        return self._logger.is_enabled(severity_number=severity_number, context=context)
+
     def emit(self, record: LogRecord) -> None:
         self._logger.emit(record)
 

opentelemetry-api/src/opentelemetry/_logs/__init__.py

@@ -592,6 +592,14 @@ def __init__(
     def resource(self):
         return self._resource
 
+    def is_enabled(
+        self,
+        severity_number: Optional[SeverityNumber] = None,
+        context: Optional[Context] = None
+    ) -> bool:
+        """Returns True if the logger is enabled for given severity and context, False otherwise."""
+        return True # TODO
+
     def emit(self, record: LogRecord):
         """Emits the :class:`LogData` by associating :class:`LogRecord`
         and instrumentation info.
@@ -603,28 +611,34 @@ def emit_event(
         self,
         name: str,
         timestamp: Optional[int] = None,
+        observed_timestamp: Optional[int] = None,
+        severity_number: Optional[SeverityNumber] = None,
+        severity_text: Optional[str] = None,
         context: Optional[Context] = None,
         body: Optional[Any] = None,
-        severity_number: Optional[SeverityNumber] = None,
         attributes: Optional[Attributes] = None,
     ) -> None:
         """Emits the :class:`LogData` by associating :class:`LogRecord`
         and instrumentation info.
         """
-        event_attributes = {**(attributes or {}), "event.name": name}
-
-        current_span_context = get_current_span(context).get_span_context()
-        self.emit(
-            LogRecord(
-                timestamp=timestamp or time_ns(),
-                trace_id=current_span_context.trace_id,
-                span_id=current_span_context.span_id,
-                trace_flags=current_span_context.trace_flags,
-                severity_number=severity_number,
-                body=body,
-                attributes=event_attributes,
+
+        if self.is_enabled(severity_number, context):
+            event_attributes = {**(attributes or {}), "event.name": name}
+
+            current_span_context = get_current_span(context).get_span_context()
+            self.emit(
+                LogRecord(
+                    timestamp=timestamp or time_ns(),
+                    observed_timestamp=observed_timestamp or time_ns(),
+                    trace_id=current_span_context.trace_id,
+                    span_id=current_span_context.span_id,
+                    trace_flags=current_span_context.trace_flags,
+                    severity_text=severity_text,
+                    severity_number=severity_number,
+                    body=body,
+                    attributes=event_attributes,
+                )
             )
-        )
 
 
 class LoggerProvider(APILoggerProvider):