Sdk builder

examples/sdk_builder.php

@@ -0,0 +1,79 @@
+<?php
+
+declare(strict_types=1);
+
+use GuzzleHttp\Client;
+use GuzzleHttp\Psr7\HttpFactory;
+use OpenTelemetry\API\Common\Instrumentation\CachedInstrumentation;
+use OpenTelemetry\API\Trace\Propagation\TraceContextPropagator;
+use OpenTelemetry\Contrib\Otlp\MetricExporter;
+use OpenTelemetry\SDK\Common\Export\Http\PsrTransportFactory;
+use OpenTelemetry\SDK\Common\Time\ClockFactory;
+use OpenTelemetry\SDK\Metrics\MeterProvider;
+use OpenTelemetry\SDK\Metrics\MetricReader\ExportingReader;
+use OpenTelemetry\SDK\Resource\ResourceInfoFactory;
+use OpenTelemetry\SDK\Sdk;
+use OpenTelemetry\SDK\Trace\Sampler\AlwaysOnSampler;
+use OpenTelemetry\SDK\Trace\Sampler\ParentBased;
+use OpenTelemetry\SDK\Trace\SpanExporter\InMemoryExporter;
+use OpenTelemetry\SDK\Trace\SpanProcessor\BatchSpanProcessorBuilder;
+use OpenTelemetry\SDK\Trace\TracerProvider;
+
+require __DIR__ . '/../vendor/autoload.php';
+
+echo 'Starting SDK builder example' . PHP_EOL;
+
+\OpenTelemetry\SDK\Common\Log\LoggerHolder::set(new \Monolog\Logger('grpc', [new \Monolog\Handler\StreamHandler('php://stderr')]));
+
+$resource = ResourceInfoFactory::defaultResource();
+$spanExporter = new InMemoryExporter();
+
+$reader = new ExportingReader(
+    new MetricExporter(
+        (new PsrTransportFactory(new Client(), new HttpFactory(), new HttpFactory()))
+            ->create('http://collector:4318/v1/metrics', 'application/x-protobuf')
+    ),
+    ClockFactory::getDefault()
+);
+
+$meterProvider = MeterProvider::builder()
+    ->setResource($resource)
+    ->addReader($reader)
+    ->build();
+
+$tracerProvider = TracerProvider::builder()
+    ->addSpanProcessor(
+        (new BatchSpanProcessorBuilder($spanExporter))
+            ->setMeterProvider($meterProvider)
+            ->build()
+    )
+    ->setResource($resource)
+    ->setSampler(new ParentBased(new AlwaysOnSampler()))
+    ->build();
+
+Sdk::builder()
+    ->setTracerProvider($tracerProvider)
+    ->setMeterProvider($meterProvider)
+    ->setPropagator(TraceContextPropagator::getInstance())
+    ->setAutoShutdown(true)
+    ->buildAndRegisterGlobal();
+
+$instrumentation = new CachedInstrumentation('example');
+$tracer = $instrumentation->tracer();
+
+$root = $tracer->spanBuilder('root')->startSpan();
+$scope = $root->activate();
+for ($i=0; $i < 100; $i++) {
+    if ($i%8 === 0) {
+        $reader->collect();
+    }
+    $tracer->spanBuilder('span-' . $i)
+        ->startSpan()
+        ->end();
+    usleep(50000);
+}
+$scope->detach();
+$root->end();
+$reader->shutdown();
+
+echo 'Finished SDK builder example' . PHP_EOL;

src/SDK/Metrics/MeterProvider.php

@@ -13,7 +13,7 @@
 use OpenTelemetry\SDK\Metrics\Exemplar\ExemplarFilterInterface;
 use OpenTelemetry\SDK\Metrics\MetricFactory\StreamFactory;
 use OpenTelemetry\SDK\Resource\ResourceInfo;
-use OpenTelemetry\SDK\SDK;
+use OpenTelemetry\SDK\Sdk;
 
 final class MeterProvider implements MeterProviderInterface
 {
@@ -65,7 +65,7 @@ public function getMeter(
         ?string $schemaUrl = null,
         iterable $attributes = []
     ): MeterInterface {
-        if ($this->closed || SDK::isDisabled()) {
+        if ($this->closed || Sdk::isDisabled()) { //@todo create meter provider from factory, and move Sdk::isDisabled() there
             return new NoopMeter();
         }
 
@@ -117,4 +117,9 @@ public function forceFlush(): bool
 
         return $success;
     }
+
+    public static function builder(): MeterProviderBuilder
+    {
+        return new MeterProviderBuilder();
+    }
 }

src/SDK/Metrics/MeterProviderBuilder.php

@@ -0,0 +1,60 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\SDK\Metrics;
+
+use OpenTelemetry\SDK\Common\Attribute\Attributes;
+use OpenTelemetry\SDK\Common\Instrumentation\InstrumentationScopeFactory;
+use OpenTelemetry\SDK\Common\Time\ClockFactory;
+use OpenTelemetry\SDK\Metrics\Exemplar\ExemplarFilter\WithSampledTraceExemplarFilter;
+use OpenTelemetry\SDK\Metrics\StalenessHandler\ImmediateStalenessHandlerFactory;
+use OpenTelemetry\SDK\Metrics\View\CriteriaViewRegistry;
+use OpenTelemetry\SDK\Resource\ResourceInfo;
+use OpenTelemetry\SDK\Resource\ResourceInfoFactory;
+
+class MeterProviderBuilder
+{
+    // @var array<MetricReaderInterface>
+    private array $metricReaders = [];
+    private ?ResourceInfo $resource = null;
+
+    public function registerMetricReader(MetricReaderInterface $reader): self
+    {
+        $this->metricReaders[] = $reader;
+
+        return $this;
+    }
+
+    public function setResource(ResourceInfo $resource): self
+    {
+        $this->resource = $resource;
+
+        return $this;
+    }
+
+    public function addReader(MetricReaderInterface $reader): self
+    {
+        $this->metricReaders[] = $reader;
+
+        return $this;
+    }
+
+    /**
+     * @psalm-suppress PossiblyInvalidArgument
+     */
+    public function build(): MeterProviderInterface
+    {
+        return new MeterProvider(
+            null,
+            $this->resource ?? ResourceInfoFactory::emptyResource(),
+            ClockFactory::getDefault(),
+            Attributes::factory(),
+            new InstrumentationScopeFactory(Attributes::factory()),
+            $this->metricReaders,
+            new CriteriaViewRegistry(),
+            new WithSampledTraceExemplarFilter(),
+            new ImmediateStalenessHandlerFactory(),
+        );
+    }
+}

src/SDK/Metrics/NoopMeterProvider.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\SDK\Metrics;
+
+use OpenTelemetry\API\Metrics\MeterInterface;
+use OpenTelemetry\API\Metrics\Noop\NoopMeter;
+
+class NoopMeterProvider implements MeterProviderInterface
+{
+    public function shutdown(): bool
+    {
+        return true;
+    }
+
+    public function forceFlush(): bool
+    {
+        return true;
+    }
+
+    public function getMeter(string $name, ?string $version = null, ?string $schemaUrl = null, iterable $attributes = []): MeterInterface
+    {
+        return new NoopMeter();
+    }
+}

src/SDK/Sdk.php

@@ -0,0 +1,53 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\SDK;
+
+use OpenTelemetry\API\Metrics\MeterProviderInterface;
+use OpenTelemetry\API\Trace\TracerProviderInterface;
+use OpenTelemetry\Context\Propagation\TextMapPropagatorInterface;
+use OpenTelemetry\SDK\Common\Environment\EnvironmentVariables;
+use OpenTelemetry\SDK\Common\Environment\Variables;
+
+class Sdk
+{
+    private TracerProviderInterface $tracerProvider;
+    private MeterProviderInterface $meterProvider;
+    private TextMapPropagatorInterface $propagator;
+
+    public function __construct(
+        TracerProviderInterface $tracerProvider,
+        MeterProviderInterface $meterProvider,
+        TextMapPropagatorInterface $propagator
+    ) {
+        $this->tracerProvider = $tracerProvider;
+        $this->meterProvider = $meterProvider;
+        $this->propagator = $propagator;
+    }
+
+    public static function isDisabled(): bool
+    {
+        return EnvironmentVariables::getBoolean(Variables::OTEL_SDK_DISABLED);
+    }
+
+    public static function builder(): SdkBuilder
+    {
+        return new SdkBuilder();
+    }
+
+    public function getTracerProvider(): TracerProviderInterface
+    {
+        return $this->tracerProvider;
+    }
+
+    public function getMeterProvider(): MeterProviderInterface
+    {
+        return $this->meterProvider;
+    }
+
+    public function getPropagator(): TextMapPropagatorInterface
+    {
+        return $this->propagator;
+    }
+}

src/SDK/SdkBuilder.php

@@ -0,0 +1,84 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\SDK;
+
+use OpenTelemetry\API\Common\Instrumentation\Configurator;
+use OpenTelemetry\Context\Context;
+use OpenTelemetry\Context\Propagation\NoopTextMapPropagator;
+use OpenTelemetry\Context\Propagation\TextMapPropagatorInterface;
+use OpenTelemetry\Context\ScopeInterface;
+use OpenTelemetry\SDK\Common\Future\CancellationInterface;
+use OpenTelemetry\SDK\Common\Util\ShutdownHandler;
+use OpenTelemetry\SDK\Metrics\MeterProviderInterface;
+use OpenTelemetry\SDK\Metrics\NoopMeterProvider;
+use OpenTelemetry\SDK\Trace\NoopTracerProvider;
+use OpenTelemetry\SDK\Trace\TracerProviderInterface;
+
+class SdkBuilder
+{
+    private ?TracerProviderInterface $tracerProvider = null;
+    private ?MeterProviderInterface  $meterProvider = null;
+    private ?TextMapPropagatorInterface $propagator = null;
+    private bool $autoShutdown = false;
+
+    /**
+     * Automatically shut down providers on process completion. If not set, the user is responsible for calling `shutdown`.
+     */
+    public function setAutoShutdown(bool $shutdown): self
+    {
+        $this->autoShutdown = $shutdown;
+
+        return $this;
+    }
+
+    public function setTracerProvider(TracerProviderInterface $provider): self
+    {
+        $this->tracerProvider = $provider;
+
+        return $this;
+    }
+
+    public function setMeterProvider(MeterProviderInterface $meterProvider): self
+    {
+        $this->meterProvider = $meterProvider;
+
+        return $this;
+    }
+
+    public function setPropagator(TextMapPropagatorInterface $propagator): self
+    {
+        $this->propagator = $propagator;
+
+        return $this;
+    }
+
+    public function build(): Sdk
+    {
+        $tracerProvider = $this->tracerProvider ?? new NoopTracerProvider();
+        $meterProvider = $this->meterProvider ?? new NoopMeterProvider();
+        if ($this->autoShutdown) {
+            ShutdownHandler::register(fn (?CancellationInterface $cancellation = null): bool => $tracerProvider->shutdown($cancellation));
+            ShutdownHandler::register(fn (): bool => $meterProvider->shutdown());
+        }
+
+        return new Sdk(
+            $tracerProvider,
+            $meterProvider,
+            $this->propagator ?? NoopTextMapPropagator::getInstance(),
+        );
+    }
+
+    public function buildAndRegisterGlobal(): ScopeInterface
+    {
+        $sdk = $this->build();
+        $context = Configurator::create()
+            ->withPropagator($sdk->getPropagator())
+            ->withTracerProvider($sdk->getTracerProvider())
+            ->withMeterProvider($sdk->getMeterProvider())
+            ->storeInContext();
+
+        return Context::storage()->attach($context);
+    }
+}

src/SDK/Trace/SpanProcessor/BatchSpanProcessorBuilder.php

@@ -0,0 +1,41 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\SDK\Trace\SpanProcessor;
+
+use OpenTelemetry\SDK\Common\Time\ClockFactory;
+use OpenTelemetry\SDK\Metrics\MeterProviderInterface;
+use OpenTelemetry\SDK\Trace\SpanExporterInterface;
+
+class BatchSpanProcessorBuilder
+{
+    private SpanExporterInterface $exporter;
+    private ?MeterProviderInterface $meterProvider = null;
+
+    public function __construct(SpanExporterInterface $exporter)
+    {
+        $this->exporter = $exporter;
+    }
+
+    public function setMeterProvider(MeterProviderInterface $meterProvider): self
+    {
+        $this->meterProvider = $meterProvider;
+
+        return $this;
+    }
+
+    public function build(): BatchSpanProcessor
+    {
+        return new BatchSpanProcessor(
+            $this->exporter,
+            ClockFactory::getDefault(),
+            BatchSpanProcessor::DEFAULT_MAX_QUEUE_SIZE,
+            BatchSpanProcessor::DEFAULT_SCHEDULE_DELAY,
+            BatchSpanProcessor::DEFAULT_EXPORT_TIMEOUT,
+            BatchSpanProcessor::DEFAULT_MAX_EXPORT_BATCH_SIZE,
+            true,
+            $this->meterProvider
+        );
+    }
+}