blob: 1969a5426623c68a58e1ae8ae3fdfab3d89028a6 (
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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
<?php
declare(strict_types=1);
namespace OpenTelemetry\SDK\Trace\SpanExporter;
use OpenTelemetry\SDK\Trace\Behavior\LoggerAwareTrait;
use OpenTelemetry\SDK\Trace\Behavior\SpanExporterTrait;
use OpenTelemetry\SDK\Trace\Behavior\UsesSpanConverterTrait;
use OpenTelemetry\SDK\Trace\SpanConverterInterface;
use OpenTelemetry\SDK\Trace\SpanExporterInterface;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerInterface;
use Psr\Log\LogLevel;
use Psr\Log\NullLogger;
use Throwable;
class LoggerExporter implements SpanExporterInterface, LoggerAwareInterface
{
use SpanExporterTrait;
use UsesSpanConverterTrait;
use LoggerAwareTrait;
public const GRANULARITY_AGGREGATE = 1;
public const GRANULARITY_SPAN = 2;
private string $serviceName;
private int $granularity = self::GRANULARITY_AGGREGATE;
/**
* @param string $serviceName
* @param LoggerInterface|null $logger
* @param string|null $defaultLogLevel
* @param SpanConverterInterface|null $converter
* @param int $granularity
*/
public function __construct(
string $serviceName,
?LoggerInterface $logger = null,
?string $defaultLogLevel = LogLevel::DEBUG,
?SpanConverterInterface $converter = null,
int $granularity = 1
) {
$this->setServiceName($serviceName);
$this->setLogger($logger ?? new NullLogger());
$this->setDefaultLogLevel($defaultLogLevel ?? LogLevel::DEBUG);
$this->setSpanConverter($converter ?? new FriendlySpanConverter());
$this->setGranularity($granularity);
}
/** @inheritDoc */
public function doExport(iterable $spans): bool
{
try {
$this->doLog($spans);
} catch (Throwable $t) {
return false;
}
return true;
}
/**
* @param string $serviceName
*/
private function setServiceName(string $serviceName): void
{
$this->serviceName = $serviceName;
}
/**
* @param int $granularity
*/
public function setGranularity(int $granularity): void
{
$this->granularity = $granularity === self::GRANULARITY_SPAN
? self::GRANULARITY_SPAN
: self::GRANULARITY_AGGREGATE;
}
/**
* @param iterable $spans
*/
private function doLog(iterable $spans): void
{
if ($this->granularity === self::GRANULARITY_AGGREGATE) {
$this->log($this->serviceName, $this->getSpanConverter()->convert($spans));
return;
}
foreach ($spans as $span) {
$this->log($this->serviceName, $this->getSpanConverter()->convert([$span]));
}
}
}
|
