Add configuration manager

Author: ocelotl

docs/index.rst

@@ -18,7 +18,6 @@ and integration packages.
    opentelemetry.context
    opentelemetry.metrics
    opentelemetry.trace
-   opentelemetry.util.loader
 
 .. toctree::
     :maxdepth: 1

docs/opentelemetry.util.loader.rst

@@ -0,0 +1,25 @@
+# Copyright 2020, OpenTelemetry Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+from os import environ
+
+
+def pytest_sessionstart(session):  # pylint: disable=unused-argument
+    environ["OPENTELEMETRY_PYTHON_TRACER_PROVIDER"] = "sdk_tracer_provider"
+    environ["OPENTELEMETRY_PYTHON_METER_PROVIDER"] = "sdk_meter_provider"
+
+
+def pytest_sessionfinish(session):  # pylint: disable=unused-argument
+    environ.pop("OPENTELEMETRY_PYTHON_TRACER_PROVIDER")
+    environ.pop("OPENTELEMETRY_PYTHON_METER_PROVIDER")

examples/basic_tracer/tests/conftest.py

@@ -17,7 +17,6 @@
 import os
 
 from opentelemetry import trace
-from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import (
     BatchExportSpanProcessor,
     ConsoleSpanExporter,
@@ -45,10 +44,6 @@
     print("Using ConsoleSpanExporter")
     exporter = ConsoleSpanExporter()
 
-# The preferred tracer implementation must be set, as the opentelemetry-api
-# defines the interface with a no-op implementation.
-trace.set_preferred_tracer_provider_implementation(lambda T: TracerProvider())
-
 # We tell OpenTelemetry who it is that is creating spans. In this case, we have
 # no real name (no setup.py), so we make one up. If we had a version, we would
 # also specify it here.
@@ -57,7 +52,7 @@
 # SpanExporter receives the spans and send them to the target location.
 span_processor = BatchExportSpanProcessor(exporter)
 
-trace.tracer_provider().add_span_processor(span_processor)
+trace.get_tracer_provider().add_span_processor(span_processor)
 with tracer.start_as_current_span("foo"):
     with tracer.start_as_current_span("bar"):
         with tracer.start_as_current_span("baz"):

examples/basic_tracer/tracer.py

@@ -22,7 +22,6 @@
 from opentelemetry import trace
 from opentelemetry.ext import http_requests
 from opentelemetry.ext.wsgi import OpenTelemetryMiddleware
-from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import (
     BatchExportSpanProcessor,
     ConsoleSpanExporter,
@@ -39,19 +38,16 @@
 else:
     exporter = ConsoleSpanExporter()
 
-# The preferred tracer implementation must be set, as the opentelemetry-api
-# defines the interface with a no-op implementation.
-trace.set_preferred_tracer_provider_implementation(lambda T: TracerProvider())
 tracer = trace.get_tracer(__name__)
 
 # SpanExporter receives the spans and send them to the target location.
 span_processor = BatchExportSpanProcessor(exporter)
-trace.tracer_provider().add_span_processor(span_processor)
+trace.get_tracer_provider().add_span_processor(span_processor)
 
 # Integrations are the glue that binds the OpenTelemetry API and the
 # frameworks and libraries that are used together, automatically creating
 # Spans and propagating context as appropriate.
-http_requests.enable(trace.tracer_provider())
+http_requests.enable(trace.get_tracer_provider())
 app = flask.Flask(__name__)
 app.wsgi_app = OpenTelemetryMiddleware(app.wsgi_app)
 

examples/http/server.py

@@ -0,0 +1,25 @@
+# Copyright 2020, OpenTelemetry Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+from os import environ
+
+
+def pytest_sessionstart(session):  # pylint: disable=unused-argument
+    environ["OPENTELEMETRY_PYTHON_TRACER_PROVIDER"] = "sdk_tracer_provider"
+    environ["OPENTELEMETRY_PYTHON_METER_PROVIDER"] = "sdk_meter_provider"
+
+
+def pytest_sessionfinish(session):  # pylint: disable=unused-argument
+    environ.pop("OPENTELEMETRY_PYTHON_TRACER_PROVIDER")
+    environ.pop("OPENTELEMETRY_PYTHON_METER_PROVIDER")

examples/http/tests/conftest.py

@@ -19,11 +19,10 @@
 
 
 class TestHttpExample(unittest.TestCase):
-    @classmethod
-    def setup_class(cls):
+    def setUp(self):
         dirpath = os.path.dirname(os.path.realpath(__file__))
         server_script = "{}/../server.py".format(dirpath)
-        cls.server = subprocess.Popen([sys.executable, server_script])
+        self.server = subprocess.Popen([sys.executable, server_script])
         sleep(1)
 
     def test_http(self):
@@ -34,6 +33,5 @@ def test_http(self):
         ).decode()
         self.assertIn('name="/"', output)
 
-    @classmethod
-    def teardown_class(cls):
-        cls.server.terminate()
+    def tearDown(self):
+        self.server.terminate()

examples/http/tests/test_http.py

@@ -20,7 +20,6 @@
 
 from opentelemetry import trace
 from opentelemetry.ext import http_requests
-from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import (
     BatchExportSpanProcessor,
     ConsoleSpanExporter,
@@ -37,10 +36,7 @@
 else:
     exporter = ConsoleSpanExporter()
 
-# The preferred tracer implementation must be set, as the opentelemetry-api
-# defines the interface with a no-op implementation.
-trace.set_preferred_tracer_provider_implementation(lambda T: TracerProvider())
-tracer_provider = trace.tracer_provider()
+tracer_provider = trace.get_tracer_provider()
 
 # SpanExporter receives the spans and send them to the target location.
 span_processor = BatchExportSpanProcessor(exporter)

examples/http/tracer_client.py

@@ -19,15 +19,14 @@
 import psutil
 
 from opentelemetry import metrics
-from opentelemetry.sdk.metrics import LabelSet, MeterProvider
+from opentelemetry.sdk.metrics import LabelSet
 from opentelemetry.sdk.metrics.export import ConsoleMetricsExporter
 from opentelemetry.sdk.metrics.export.batcher import UngroupedBatcher
 from opentelemetry.sdk.metrics.export.controller import PushController
 
 # Configure a stateful batcher
 batcher = UngroupedBatcher(stateful=True)
 
-metrics.set_preferred_meter_provider_implementation(lambda _: MeterProvider())
 meter = metrics.get_meter(__name__)
 
 # Exporter to export metrics to the console

examples/metrics/observer_example.py

@@ -21,14 +21,13 @@
 
 from opentelemetry import metrics
 from opentelemetry.ext.prometheus import PrometheusMetricsExporter
-from opentelemetry.sdk.metrics import Counter, MeterProvider
+from opentelemetry.sdk.metrics import Counter
 from opentelemetry.sdk.metrics.export.controller import PushController
 
 # Start Prometheus client
 start_http_server(port=8000, addr="localhost")
 
 # Meter is responsible for creating and recording metrics
-metrics.set_preferred_meter_provider_implementation(lambda _: MeterProvider())
 meter = metrics.get_meter(__name__)
 # exporter to export metrics to Prometheus
 prefix = "MyAppPrefix"

examples/metrics/prometheus.py

@@ -19,13 +19,10 @@
 import time
 
 from opentelemetry import metrics
-from opentelemetry.sdk.metrics import Counter, MeterProvider
+from opentelemetry.sdk.metrics import Counter
 from opentelemetry.sdk.metrics.export import ConsoleMetricsExporter
 from opentelemetry.sdk.metrics.export.controller import PushController
 
-# The preferred tracer implementation must be set, as the opentelemetry-api
-# defines the interface with a no-op implementation.
-metrics.set_preferred_meter_provider_implementation(lambda _: MeterProvider())
 # Meter is responsible for creating and recording metrics
 meter = metrics.get_meter(__name__)
 # exporter to export metrics to the console

examples/metrics/record.py

@@ -23,7 +23,7 @@
 import time
 
 from opentelemetry import metrics
-from opentelemetry.sdk.metrics import Counter, Measure, MeterProvider
+from opentelemetry.sdk.metrics import Counter, Measure
 from opentelemetry.sdk.metrics.export import ConsoleMetricsExporter
 from opentelemetry.sdk.metrics.export.controller import PushController
 
@@ -44,7 +44,6 @@ def usage(argv):
         sys.exit(1)
 
 # Meter is responsible for creating and recording metrics
-metrics.set_preferred_meter_provider_implementation(lambda _: MeterProvider())
 
 # Meter's namespace corresponds to the string passed as the first argument Pass
 # in True/False to indicate whether the batcher is stateful. True indicates the

examples/metrics/simple_example.py

@@ -23,7 +23,6 @@
 import opentelemetry.ext.http_requests
 from opentelemetry import trace
 from opentelemetry.ext.flask import instrument_app
-from opentelemetry.sdk.trace import TracerProvider
 
 
 def configure_opentelemetry(flask_app: flask.Flask):
@@ -42,20 +41,14 @@ def configure_opentelemetry(flask_app: flask.Flask):
     """
     # Start by configuring all objects required to ensure
     # a complete end to end workflow.
-    # The preferred implementation of these objects must be set,
-    # as the opentelemetry-api defines the interface with a no-op
-    # implementation.
-    trace.set_preferred_tracer_provider_implementation(
-        lambda _: TracerProvider()
-    )
 
     # Next, we need to configure how the values that are used by
     # traces and metrics are propagated (such as what specific headers
     # carry this value).
     # Integrations are the glue that binds the OpenTelemetry API
     # and the frameworks and libraries that are used together, automatically
     # creating Spans and propagating context as appropriate.
-    opentelemetry.ext.http_requests.enable(trace.tracer_provider())
+    opentelemetry.ext.http_requests.enable(trace.get_tracer_provider())
     instrument_app(flask_app)
 
 

examples/opentelemetry-example-app/src/opentelemetry_example_app/flask_example.py

@@ -0,0 +1,25 @@
+# Copyright 2020, OpenTelemetry Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+from os import environ
+
+
+def pytest_sessionstart(session):  # pylint: disable=unused-argument
+    environ["OPENTELEMETRY_PYTHON_TRACER_PROVIDER"] = "sdk_tracer_provider"
+    environ["OPENTELEMETRY_PYTHON_METER_PROVIDER"] = "sdk_meter_provider"
+
+
+def pytest_sessionfinish(session):  # pylint: disable=unused-argument
+    environ.pop("OPENTELEMETRY_PYTHON_TRACER_PROVIDER")
+    environ.pop("OPENTELEMETRY_PYTHON_METER_PROVIDER")

examples/opentelemetry-example-app/tests/conftest.py

@@ -3,13 +3,10 @@
 from opentelemetry import trace
 from opentelemetry.ext import opentracing_shim
 from opentelemetry.ext.jaeger import JaegerSpanExporter
-from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import SimpleExportSpanProcessor
 from rediscache import RedisCache
 
-# Configure the tracer using the default implementation
-trace.set_preferred_tracer_provider_implementation(lambda T: TracerProvider())
-tracer_provider = trace.tracer_provider()
+tracer_provider = trace.get_tracer_provider()
 
 # Configure the tracer to export traces to Jaeger
 jaeger_exporter = JaegerSpanExporter(

examples/opentracing/main.py

@@ -14,7 +14,6 @@ Usage
     from opentelemetry.trace import tracer_provider
     from opentelemetry.ext.dbapi import trace_integration
 
-    trace.set_preferred_tracer_provider_implementation(lambda T: TracerProvider())
     tracer = trace.get_tracer(__name__)
     # Ex: mysql.connector
     trace_integration(tracer_provider(), mysql.connector, "connect", "mysql")

ext/opentelemetry-ext-dbapi/README.rst

@@ -0,0 +1,25 @@
+# Copyright 2020, OpenTelemetry Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+from os import environ
+
+
+def pytest_sessionstart(session):  # pylint: disable=unused-argument
+    environ["OPENTELEMETRY_PYTHON_TRACER_PROVIDER"] = "sdk_tracer_provider"
+    environ["OPENTELEMETRY_PYTHON_METER_PROVIDER"] = "sdk_meter_provider"
+
+
+def pytest_sessionfinish(session):  # pylint: disable=unused-argument
+    environ.pop("OPENTELEMETRY_PYTHON_TRACER_PROVIDER")
+    environ.pop("OPENTELEMETRY_PYTHON_METER_PROVIDER")

ext/opentelemetry-ext-flask/tests/conftest.py

@@ -32,10 +32,8 @@ gRPC is still not supported by this implementation.
 
     from opentelemetry import trace
     from opentelemetry.ext import jaeger
-    from opentelemetry.sdk.trace import TracerProvider
     from opentelemetry.sdk.trace.export import BatchExportSpanProcessor
 
-    trace.set_preferred_tracer_provider_implementation(lambda T: TracerProvider())
     tracer = trace.get_tracer(__name__)
 
     # create a JaegerSpanExporter

ext/opentelemetry-ext-jaeger/README.rst

@@ -2,10 +2,8 @@
 
 from opentelemetry import trace
 from opentelemetry.ext import jaeger
-from opentelemetry.sdk.trace import TracerProvider
 from opentelemetry.sdk.trace.export import BatchExportSpanProcessor
 
-trace.set_preferred_tracer_provider_implementation(lambda T: TracerProvider())
 tracer = trace.get_tracer(__name__)
 
 # create a JaegerSpanExporter
@@ -26,7 +24,7 @@
 span_processor = BatchExportSpanProcessor(jaeger_exporter)
 
 # add to the tracer factory
-trace.tracer_provider().add_span_processor(span_processor)
+trace.get_tracer_provider().add_span_processor(span_processor)
 
 # create some spans for testing
 with tracer.start_as_current_span("foo") as foo:

ext/opentelemetry-ext-jaeger/examples/jaeger_exporter_example.py

@@ -29,12 +29,8 @@
     import time
 
     from opentelemetry import trace
-    from opentelemetry.sdk.trace import TracerProvider
     from opentelemetry.ext.opentracing_shim import create_tracer
 
-    # Tell OpenTelemetry which Tracer implementation to use.
-    trace.set_preferred_tracer_provider_implementation(lambda T: TracerProvider())
-
     # Create an OpenTelemetry Tracer.
     otel_tracer = trace.get_tracer(__name__)