move logs to _logs (#2240)

* move logs to _logs

* fix lint

docs/examples/logs/example.py

@@ -2,12 +2,12 @@
 
 from opentelemetry import trace
 from opentelemetry.exporter.otlp.proto.grpc.log_exporter import OTLPLogExporter
-from opentelemetry.sdk.logs import (
+from opentelemetry.sdk._logs import (
     LogEmitterProvider,
     OTLPHandler,
     set_log_emitter_provider,
 )
-from opentelemetry.sdk.logs.export import BatchLogProcessor
+from opentelemetry.sdk._logs.export import BatchLogProcessor
 from opentelemetry.sdk.resources import Resource
 from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import (

docs/sdk/logs.export.rst

@@ -1,7 +1,7 @@
-opentelemetry.sdk.logs.export
-=============================
+opentelemetry.sdk._logs.export
+==============================
 
-.. automodule:: opentelemetry.sdk.logs.export
+.. automodule:: opentelemetry.sdk._logs.export
     :members:
     :undoc-members:
-    :show-inheritance:
+    :show-inheritance:

docs/sdk/logs.rst

@@ -1,4 +1,4 @@
-opentelemetry.sdk.logs package
+opentelemetry.sdk._logs package
 ===============================
 
 Submodules
@@ -9,7 +9,7 @@ Submodules
    logs.export
    logs.severity
 
-.. automodule:: opentelemetry.sdk.logs
+.. automodule:: opentelemetry.sdk._logs
     :members:
     :undoc-members:
     :show-inheritance:

docs/sdk/logs.severity.rst

@@ -1,7 +1,7 @@
-opentelemetry.sdk.logs.severity
-===============================
+opentelemetry.sdk._logs.severity
+================================
 
-.. automodule:: opentelemetry.sdk.logs.severity
+.. automodule:: opentelemetry.sdk._logs.severity
     :members:
     :undoc-members:
     :show-inheritance:

exporter/opentelemetry-exporter-otlp-proto-grpc/src/opentelemetry/exporter/otlp/proto/grpc/log_exporter/__init__.py

@@ -31,9 +31,9 @@
     ResourceLogs,
 )
 from opentelemetry.proto.logs.v1.logs_pb2 import LogRecord as PB2LogRecord
-from opentelemetry.sdk.logs import LogRecord as SDKLogRecord
-from opentelemetry.sdk.logs import LogData
-from opentelemetry.sdk.logs.export import LogExporter, LogExportResult
+from opentelemetry.sdk._logs import LogRecord as SDKLogRecord
+from opentelemetry.sdk._logs import LogData
+from opentelemetry.sdk._logs.export import LogExporter, LogExportResult
 
 
 class OTLPLogExporter(

exporter/opentelemetry-exporter-otlp-proto-grpc/tests/logs/test_otlp_logs_exporter.py

@@ -42,9 +42,11 @@
 from opentelemetry.proto.resource.v1.resource_pb2 import (
     Resource as OTLPResource,
 )
-from opentelemetry.sdk.logs import LogData, LogRecord
-from opentelemetry.sdk.logs.export import LogExportResult
-from opentelemetry.sdk.logs.severity import SeverityNumber as SDKSeverityNumber
+from opentelemetry.sdk._logs import LogData, LogRecord
+from opentelemetry.sdk._logs.export import LogExportResult
+from opentelemetry.sdk._logs.severity import (
+    SeverityNumber as SDKSeverityNumber,
+)
 from opentelemetry.sdk.resources import Resource as SDKResource
 from opentelemetry.sdk.util.instrumentation import InstrumentationInfo
 from opentelemetry.trace import TraceFlags

opentelemetry-sdk/setup.cfg

@@ -55,7 +55,7 @@ opentelemetry_tracer_provider =
 opentelemetry_traces_exporter =
     console = opentelemetry.sdk.trace.export:ConsoleSpanExporter
 opentelemetry_log_emitter_provider =
-    sdk_log_emitter_provider = opentelemetry.sdk.logs:LogEmitterProvider
+    sdk_log_emitter_provider = opentelemetry.sdk._logs:LogEmitterProvider
 opentelemetry_id_generator =
     random = opentelemetry.sdk.trace.id_generator:RandomIdGenerator
 opentelemetry_environment_variables =

opentelemetry-sdk/src/opentelemetry/sdk/logs/__init__.py → opentelemetry-sdk/src/opentelemetry/sdk/_logs/__init__.py

@@ -21,10 +21,10 @@
 import threading
 from typing import Any, Callable, Optional, Tuple, Union, cast
 
+from opentelemetry.sdk._logs.severity import SeverityNumber, std_to_otlp
 from opentelemetry.sdk.environment_variables import (
     OTEL_PYTHON_LOG_EMITTER_PROVIDER,
 )
-from opentelemetry.sdk.logs.severity import SeverityNumber, std_to_otlp
 from opentelemetry.sdk.resources import Resource
 from opentelemetry.sdk.util import ns_to_iso_str
 from opentelemetry.sdk.util.instrumentation import InstrumentationInfo
@@ -124,7 +124,7 @@ def emit(self, log_data: LogData):
 
     @abc.abstractmethod
     def shutdown(self):
-        """Called when a :class:`opentelemetry.sdk.logs.LogEmitter` is shutdown"""
+        """Called when a :class:`opentelemetry.sdk._logs.LogEmitter` is shutdown"""
 
     @abc.abstractmethod
     def force_flush(self, timeout_millis: int = 30000):
@@ -489,7 +489,7 @@ def get_log_emitter(
     """Returns a `LogEmitter` for use within a python process.
 
     This function is a convenience wrapper for
-    opentelemetry.sdk.logs.LogEmitterProvider.get_log_emitter.
+    opentelemetry.sdk._logs.LogEmitterProvider.get_log_emitter.
 
     If log_emitter_provider param is omitted the current configured one is used.
     """

opentelemetry-sdk/src/opentelemetry/sdk/logs/export/__init__.py → opentelemetry-sdk/src/opentelemetry/sdk/_logs/export/__init__.py

@@ -22,7 +22,7 @@
 from typing import IO, Callable, Deque, List, Optional, Sequence
 
 from opentelemetry.context import attach, detach, set_value
-from opentelemetry.sdk.logs import LogData, LogProcessor, LogRecord
+from opentelemetry.sdk._logs import LogData, LogProcessor, LogRecord
 from opentelemetry.util._time import _time_ns
 
 _logger = logging.getLogger(__name__)
@@ -39,7 +39,7 @@ class LogExporter(abc.ABC):
     Interface to be implemented by services that want to export logs received
     in their own format.
 
-    To export data this MUST be registered to the :class`opentelemetry.sdk.logs.LogEmitter` using a
+    To export data this MUST be registered to the :class`opentelemetry.sdk._logs.LogEmitter` using a
     log processor.
     """
 

opentelemetry-sdk/src/opentelemetry/sdk/logs/export/in_memory_log_exporter.py → opentelemetry-sdk/src/opentelemetry/sdk/_logs/export/in_memory_log_exporter.py

@@ -15,8 +15,8 @@
 import threading
 import typing
 
-from opentelemetry.sdk.logs import LogData
-from opentelemetry.sdk.logs.export import LogExporter, LogExportResult
+from opentelemetry.sdk._logs import LogData
+from opentelemetry.sdk._logs.export import LogExporter, LogExportResult
 
 
 class InMemoryLogExporter(LogExporter):

opentelemetry-sdk/tests/logs/test_export.py

@@ -21,21 +21,21 @@
 from unittest.mock import Mock, patch
 
 from opentelemetry.sdk import trace
-from opentelemetry.sdk.logs import (
+from opentelemetry.sdk._logs import (
     LogData,
     LogEmitterProvider,
     LogRecord,
     OTLPHandler,
 )
-from opentelemetry.sdk.logs.export import (
+from opentelemetry.sdk._logs.export import (
     BatchLogProcessor,
     ConsoleExporter,
     SimpleLogProcessor,
 )
-from opentelemetry.sdk.logs.export.in_memory_log_exporter import (
+from opentelemetry.sdk._logs.export.in_memory_log_exporter import (
     InMemoryLogExporter,
 )
-from opentelemetry.sdk.logs.severity import SeverityNumber
+from opentelemetry.sdk._logs.severity import SeverityNumber
 from opentelemetry.sdk.resources import Resource as SDKResource
 from opentelemetry.sdk.util.instrumentation import InstrumentationInfo
 from opentelemetry.trace import TraceFlags

opentelemetry-sdk/tests/logs/test_global_provider.py

@@ -18,20 +18,20 @@
 from logging import WARNING
 from unittest.mock import patch
 
-from opentelemetry.sdk import logs
-from opentelemetry.sdk.environment_variables import (
-    OTEL_PYTHON_LOG_EMITTER_PROVIDER,
-)
-from opentelemetry.sdk.logs import (
+from opentelemetry.sdk import _logs
+from opentelemetry.sdk._logs import (
     LogEmitterProvider,
     get_log_emitter_provider,
     set_log_emitter_provider,
 )
+from opentelemetry.sdk.environment_variables import (
+    OTEL_PYTHON_LOG_EMITTER_PROVIDER,
+)
 
 
 class TestGlobals(unittest.TestCase):
     def tearDown(self):
-        reload(logs)
+        reload(_logs)
 
     def check_override_not_allowed(self):
         """set_log_emitter_provider should throw a warning when overridden"""
@@ -42,34 +42,34 @@ def check_override_not_allowed(self):
                 test.output,
                 [
                     (
-                        "WARNING:opentelemetry.sdk.logs:Overriding of current "
+                        "WARNING:opentelemetry.sdk._logs:Overriding of current "
                         "LogEmitterProvider is not allowed"
                     )
                 ],
             )
         self.assertIs(provider, get_log_emitter_provider())
 
     def test_set_tracer_provider(self):
-        reload(logs)
+        reload(_logs)
         provider = LogEmitterProvider()
         set_log_emitter_provider(provider)
         retrieved_provider = get_log_emitter_provider()
         self.assertEqual(provider, retrieved_provider)
 
     def test_tracer_provider_override_warning(self):
-        reload(logs)
+        reload(_logs)
         self.check_override_not_allowed()
 
     @patch.dict(
         "os.environ",
         {OTEL_PYTHON_LOG_EMITTER_PROVIDER: "sdk_log_emitter_provider"},
     )
     def test_sdk_log_emitter_provider(self):
-        reload(logs)
+        reload(_logs)
         self.check_override_not_allowed()
 
     @patch.dict("os.environ", {OTEL_PYTHON_LOG_EMITTER_PROVIDER: "unknown"})
     def test_unknown_log_emitter_provider(self):
-        reload(logs)
+        reload(_logs)
         with self.assertRaises(Exception):
             get_log_emitter_provider()

opentelemetry-sdk/tests/logs/test_handler.py

@@ -17,8 +17,8 @@
 from unittest.mock import Mock
 
 from opentelemetry.sdk import trace
-from opentelemetry.sdk.logs import LogEmitter, OTLPHandler
-from opentelemetry.sdk.logs.severity import SeverityNumber
+from opentelemetry.sdk._logs import LogEmitter, OTLPHandler
+from opentelemetry.sdk._logs.severity import SeverityNumber
 from opentelemetry.trace import INVALID_SPAN_CONTEXT
 
 

opentelemetry-sdk/tests/logs/test_multi_log_prcessor.py

@@ -21,15 +21,15 @@
 from abc import ABC, abstractmethod
 from unittest.mock import Mock
 
-from opentelemetry.sdk.logs import (
+from opentelemetry.sdk._logs import (
     ConcurrentMultiLogProcessor,
     LogEmitterProvider,
     LogProcessor,
     LogRecord,
     OTLPHandler,
     SynchronousMultiLogProcessor,
 )
-from opentelemetry.sdk.logs.severity import SeverityNumber
+from opentelemetry.sdk._logs.severity import SeverityNumber
 
 
 class AnotherLogProcessor(LogProcessor):