56 lines
1.6 KiB
PHP
56 lines
1.6 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
declare(strict_types=1);
|
||
|
|
|
||
|
|
namespace OpenTelemetry\SDK\Propagation;
|
||
|
|
|
||
|
|
use OpenTelemetry\API\Behavior\LogsMessagesTrait;
|
||
|
|
use OpenTelemetry\Context\Propagation\MultiTextMapPropagator;
|
||
|
|
use OpenTelemetry\Context\Propagation\NoopTextMapPropagator;
|
||
|
|
use OpenTelemetry\Context\Propagation\TextMapPropagatorInterface;
|
||
|
|
use OpenTelemetry\SDK\Common\Configuration\Configuration;
|
||
|
|
use OpenTelemetry\SDK\Common\Configuration\Variables;
|
||
|
|
use OpenTelemetry\SDK\Registry;
|
||
|
|
|
||
|
|
class PropagatorFactory
|
||
|
|
{
|
||
|
|
use LogsMessagesTrait;
|
||
|
|
|
||
|
|
public function create(): TextMapPropagatorInterface
|
||
|
|
{
|
||
|
|
$propagators = Configuration::getList(Variables::OTEL_PROPAGATORS);
|
||
|
|
switch (count($propagators)) {
|
||
|
|
case 0:
|
||
|
|
return new NoopTextMapPropagator();
|
||
|
|
case 1:
|
||
|
|
return $this->buildPropagator($propagators[0]);
|
||
|
|
default:
|
||
|
|
return new MultiTextMapPropagator($this->buildPropagators($propagators));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @return array<TextMapPropagatorInterface>
|
||
|
|
*/
|
||
|
|
private function buildPropagators(array $names): array
|
||
|
|
{
|
||
|
|
$propagators = [];
|
||
|
|
foreach ($names as $name) {
|
||
|
|
$propagators[] = $this->buildPropagator($name);
|
||
|
|
}
|
||
|
|
|
||
|
|
return $propagators;
|
||
|
|
}
|
||
|
|
|
||
|
|
private function buildPropagator(string $name): TextMapPropagatorInterface
|
||
|
|
{
|
||
|
|
try {
|
||
|
|
return Registry::textMapPropagator($name);
|
||
|
|
} catch (\RuntimeException $e) {
|
||
|
|
self::logWarning($e->getMessage());
|
||
|
|
}
|
||
|
|
|
||
|
|
return NoopTextMapPropagator::getInstance();
|
||
|
|
}
|
||
|
|
}
|