use SPI to manage components

composer.json

@@ -124,6 +124,43 @@
             "forward-command": true
         },
         "spi": {
+            "OpenTelemetry\\SDK\\Common\\Export\\TransportFactoryInterface": [
+                "OpenTelemetry\\SDK\\Common\\Export\\Http\\PsrTransportFactory",
+                "OpenTelemetry\\Contrib\\Otlp\\OtlpHttpTransportFactory",
+                "OpenTelemetry\\Contrib\\Grpc\\GrpcTransportFactory",
+                "OpenTelemetry\\SDK\\Common\\Export\\Stream\\StreamTransportFactory"
+            ],
+            "OpenTelemetry\\SDK\\Trace\\SpanExporter\\SpanExporterFactoryInterface": [
+                "OpenTelemetry\\SDK\\Trace\\SpanExporter\\ConsoleSpanExporterFactory",
+                "OpenTelemetry\\SDK\\Trace\\SpanExporter\\InMemorySpanExporterFactory",
+                "OpenTelemetry\\Contrib\\Otlp\\SpanExporterFactory",
+                "OpenTelemetry\\Contrib\\Zipkin\\SpanExporterFactory"
+            ],
+            "OpenTelemetry\\SDK\\Metrics\\MetricExporterFactoryInterface": [
+                "OpenTelemetry\\SDK\\Metrics\\MetricExporter\\InMemoryExporterFactory",
+                "OpenTelemetry\\SDK\\Metrics\\MetricExporter\\ConsoleMetricExporterFactory",
+                "OpenTelemetry\\SDK\\Metrics\\MetricExporter\\NoopMetricExporterFactory",
+                "OpenTelemetry\\Contrib\\Otlp\\MetricExporterFactory"
+            ],
+            "OpenTelemetry\\SDK\\Logs\\LogRecordExporterFactoryInterface": [
+                "OpenTelemetry\\SDK\\Logs\\Exporter\\ConsoleExporterFactory",
+                "OpenTelemetry\\SDK\\Logs\\Exporter\\InMemoryExporterFactory",
+                "OpenTelemetry\\Contrib\\Otlp\\LogsExporterFactory"
+            ],
+            "OpenTelemetry\\Context\\Propagation\\TextMapPropagatorFactoryInterface": [
+                    "OpenTelemetry\\API\\Baggage\\Propagation\\BaggagePropagatorFactory",
+                    "OpenTelemetry\\API\\Trace\\Propagation\\TraceContextPropagatorFactory",
+                    "OpenTelemetry\\Context\\Propagation\\NoopTextMapPropagatorFactory",
+                    "OpenTelemetry\\Extension\\Propagator\\B3\\B3PropagatorFactory",
+                    "OpenTelemetry\\Extension\\Propagator\\B3\\B3MultiPropagatorFactory",
+                    "OpenTelemetry\\Extension\\Propagator\\CloudTrace\\CloudTracePropagatorFactory",
+                    "OpenTelemetry\\Extension\\Propagator\\CloudTrace\\CloudTraceOneWayPropagatorFactory",
+                    "OpenTelemetry\\Extension\\Propagator\\Jaeger\\JaegerPropagatorFactory",
+                    "OpenTelemetry\\Extension\\Propagator\\Jaeger\\JaegerBaggagePropagatorFactory"
+            ],
+            "OpenTelemetry\\SDK\\Resource\\ResourceDetectorFactoryInterface": [
+                "OpenTelemetry\\Example\\TestResourceDetectorFactory"
+            ],
             "OpenTelemetry\\Config\\SDK\\Configuration\\ComponentProvider": [
                 "OpenTelemetry\\Config\\SDK\\ComponentProvider\\Propagator\\TextMapPropagatorB3",
                 "OpenTelemetry\\Config\\SDK\\ComponentProvider\\Propagator\\TextMapPropagatorB3Multi",

examples/autoload_sdk_with_custom_transport.php

@@ -45,6 +45,16 @@ public function forceFlush(?\OpenTelemetry\SDK\Common\Future\CancellationInterfa
             }
         };
     }
+
+    public function type(): string
+    {
+        return 'grpc';
+    }
+
+    public function priority(): int
+    {
+        return 100;
+    }
 };
 
 \OpenTelemetry\SDK\Registry::registerTransportFactory('grpc', $factory, true);

examples/src/ExampleInstrumentation.php

@@ -4,7 +4,6 @@
 
 namespace OpenTelemetry\Example;
 
-use Exception;
 use OpenTelemetry\API\Configuration\ConfigProperties;
 use OpenTelemetry\API\Instrumentation\AutoInstrumentation\Context as InstrumentationContext;
 use OpenTelemetry\API\Instrumentation\AutoInstrumentation\HookManagerInterface;
@@ -17,7 +16,7 @@ final class ExampleInstrumentation implements Instrumentation
 
     public function register(HookManagerInterface $hookManager, ConfigProperties $configuration, InstrumentationContext $context): void
     {
-        $config = $configuration->get(ExampleConfig::class) ?? throw new Exception('example instrumentation must be configured');
+        $config = $configuration->get(ExampleConfig::class) ?? new ExampleConfig('example');
         if (!$config->enabled) {
             return;
         }

examples/src/TestResourceDetector.php

@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\Example;
+
+use OpenTelemetry\SDK\Common\Attribute\Attributes;
+use OpenTelemetry\SDK\Resource\ResourceDetectorInterface;
+use OpenTelemetry\SDK\Resource\ResourceInfo;
+use OpenTelemetry\SemConv\ResourceAttributes;
+
+class TestResourceDetector implements ResourceDetectorInterface
+{
+    public function getResource(): ResourceInfo
+    {
+        $attributes = [
+            'test-resource' => 'test-value',
+        ];
+
+        return ResourceInfo::create(Attributes::create($attributes), ResourceAttributes::SCHEMA_URL);
+    }
+}

examples/src/TestResourceDetectorFactory.php

@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\Example;
+
+use OpenTelemetry\SDK\Resource\ResourceDetectorFactoryInterface;
+use OpenTelemetry\SDK\Resource\ResourceDetectorInterface;
+
+class TestResourceDetectorFactory implements ResourceDetectorFactoryInterface
+{
+
+    public function create(): ResourceDetectorInterface
+    {
+        return new TestResourceDetector();
+    }
+
+    public function type(): string
+    {
+        return 'test';
+    }
+
+    public function priority(): int
+    {
+        return 0;
+    }
+}

examples/traces/features/auto_root_span.php

@@ -8,11 +8,16 @@
 use OpenTelemetry\API\Logs\LogRecord;
 
 putenv('OTEL_PHP_AUTOLOAD_ENABLED=true');
-putenv('OTEL_TRACES_EXPORTER=console');
+putenv('OTEL_TRACES_EXPORTER=otlp');
 putenv('OTEL_METRICS_EXPORTER=none');
-putenv('OTEL_LOGS_EXPORTER=console');
+putenv('OTEL_LOGS_EXPORTER=otlp');
+putenv('OTEL_EXPORTER_OTLP_ENDPOINT=http://collector:4318');
+putenv('OTEL_EXPORTER_OTLP_PROTOCOL=http/protobuf');
 putenv('OTEL_PROPAGATORS=tracecontext');
 putenv('OTEL_PHP_EXPERIMENTAL_AUTO_ROOT_SPAN=true');
+putenv('OTEL_PHP_EXPERIMENTAL_SPI_REGISTRY=true');
+putenv('OTEL_PHP_DETECTORS=sdk,test');
+$_SERVER['REQUEST_METHOD'] = 'GET';
 
 //Usage: php -S localhost:8080 examples/traces/features/auto_root_span.php
 

phpstan.neon.dist

@@ -49,4 +49,8 @@ parameters:
         -
             message: "#.*return with type T is not subtype.*#"
             paths:
-                - src/SDK/Common/InstrumentationScope
+                - src/SDK/Common/InstrumentationScope
+        -
+            message: "#.*array_multisort.*#"
+            paths:
+                - src/SDK/Registry

psalm.xml.dist

@@ -25,6 +25,7 @@
         <UndefinedClass>
             <errorLevel type="suppress">
                 <referencedClass name="GMP"/>
+                <file name="src/SDK/Registry.php"/>
             </errorLevel>
         </UndefinedClass>
         <UndefinedFunction>
@@ -57,5 +58,10 @@
                 <directory name="src/Config/SDK/ComponentProvider"/>
             </errorLevel>
         </InvalidDocblock>
+        <InvalidPropertyAssignmentValue>
+            <errorLevel type="suppress">
+                <file name="src/SDK/Registry.php"/>
+            </errorLevel>
+        </InvalidPropertyAssignmentValue>
     </issueHandlers>
 </psalm>

src/API/Baggage/Propagation/BaggagePropagatorFactory.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\API\Baggage\Propagation;
+
+use OpenTelemetry\Context\Propagation\TextMapPropagatorFactoryInterface;
+use OpenTelemetry\Context\Propagation\TextMapPropagatorInterface;
+
+class BaggagePropagatorFactory implements TextMapPropagatorFactoryInterface
+{
+    public function create(): TextMapPropagatorInterface
+    {
+        return BaggagePropagator::getInstance();
+    }
+
+    public function type(): string
+    {
+        return 'baggage';
+    }
+
+    public function priority(): int
+    {
+        return 0;
+    }
+}

src/API/Trace/Propagation/TraceContextPropagatorFactory.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\API\Trace\Propagation;
+
+use OpenTelemetry\Context\Propagation\TextMapPropagatorFactoryInterface;
+use OpenTelemetry\Context\Propagation\TextMapPropagatorInterface;
+
+class TraceContextPropagatorFactory implements TextMapPropagatorFactoryInterface
+{
+    public function create(): TextMapPropagatorInterface
+    {
+        return TraceContextPropagator::getInstance();
+    }
+
+    public function type(): string
+    {
+        return 'tracecontext';
+    }
+
+    public function priority(): int
+    {
+        return 0;
+    }
+}

src/Context/Propagation/NoopTextMapPropagatorFactory.php

@@ -0,0 +1,23 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\Context\Propagation;
+
+class NoopTextMapPropagatorFactory implements TextMapPropagatorFactoryInterface
+{
+    public function create(): TextMapPropagatorInterface
+    {
+        return NoopTextMapPropagator::getInstance();
+    }
+
+    public function type(): string
+    {
+        return 'none';
+    }
+
+    public function priority(): int
+    {
+        return 0;
+    }
+}

src/Context/Propagation/TextMapPropagatorFactoryInterface.php

@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\Context\Propagation;
+
+interface TextMapPropagatorFactoryInterface
+{
+    public function create(): TextMapPropagatorInterface;
+    public function type(): string;
+    public function priority(): int;
+}

src/Contrib/Grpc/GrpcTransportFactory.php

@@ -157,4 +157,14 @@ private static function fileGetContents(?string $file): ?string
 
         return $content;
     }
+
+    public function type(): string
+    {
+        return 'grpc';
+    }
+
+    public function priority(): int
+    {
+        return 0;
+    }
 }

src/Contrib/Otlp/LogsExporterFactory.php

@@ -34,6 +34,16 @@ public function create(): LogRecordExporterInterface
         return new LogsExporter($this->buildTransport($protocol));
     }
 
+    public function type(): string
+    {
+        return 'otlp';
+    }
+
+    public function priority(): int
+    {
+        return 0;
+    }
+
     /**
      * @psalm-suppress UndefinedClass
      */

src/Contrib/Otlp/MetricExporterFactory.php

@@ -36,6 +36,16 @@ public function create(): MetricExporterInterface
         return new MetricExporter($this->buildTransport($protocol), $temporality);
     }
 
+    public function type(): string
+    {
+        return 'otlp';
+    }
+
+    public function priority(): int
+    {
+        return 0;
+    }
+
     /**
      * @psalm-suppress UndefinedClass
      */

src/Contrib/Otlp/OtlpHttpTransportFactory.php

@@ -31,4 +31,14 @@ public function create(
         return (new PsrTransportFactory())
             ->create($endpoint, $contentType, $headers, $compression, $timeout, $retryDelay, $maxRetries, $cacert, $cert, $key);
     }
+
+    public function type(): string
+    {
+        return 'http';
+    }
+
+    public function priority(): int
+    {
+        return 0;
+    }
 }

src/Contrib/Otlp/SpanExporterFactory.php

@@ -91,4 +91,13 @@ private function getTimeout(): float
 
         return $value/1000;
     }
+
+    public function type(): string
+    {
+        return 'otlp';
+    }
+    public function priority(): int
+    {
+        return 0;
+    }
 }

src/Contrib/Zipkin/SpanExporterFactory.php

@@ -20,4 +20,13 @@ public function create(): SpanExporterInterface
 
         return new Exporter($transport);
     }
+
+    public function type(): string
+    {
+        return 'zipkin';
+    }
+    public function priority(): int
+    {
+        return 0;
+    }
 }

src/Extension/Propagator/B3/B3MultiPropagatorFactory.php

@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\Extension\Propagator\B3;
+
+use OpenTelemetry\Context\Propagation\TextMapPropagatorFactoryInterface;
+use OpenTelemetry\Context\Propagation\TextMapPropagatorInterface;
+
+class B3MultiPropagatorFactory implements TextMapPropagatorFactoryInterface
+{
+
+    public function create(): TextMapPropagatorInterface
+    {
+        return B3Propagator::getB3MultiHeaderInstance();
+    }
+
+    public function type(): string
+    {
+        return 'b3multi';
+    }
+
+    public function priority(): int
+    {
+        return 0;
+    }
+}