blob: 2dc349dfbd00fc2bc9ed7f12370c5f17d339bd1e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
<?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();
}
}
|
