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
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
<?php
declare(strict_types=1);
namespace OpenTelemetry\SDK\Metrics;
use OpenTelemetry\API\Metrics\MeterInterface;
use OpenTelemetry\API\Metrics\Noop\NoopMeter;
use OpenTelemetry\Context\ContextStorageInterface;
use OpenTelemetry\SDK\Common\Attribute\AttributesFactoryInterface;
use OpenTelemetry\SDK\Common\Instrumentation\InstrumentationScopeFactoryInterface;
use OpenTelemetry\SDK\Common\Time\ClockInterface;
use OpenTelemetry\SDK\Metrics\Exemplar\ExemplarFilterInterface;
use OpenTelemetry\SDK\Metrics\MetricFactory\StreamFactory;
use OpenTelemetry\SDK\Metrics\MetricRegistry\MetricRegistry;
use OpenTelemetry\SDK\Metrics\MetricRegistry\MetricRegistryInterface;
use OpenTelemetry\SDK\Metrics\MetricRegistry\MetricWriterInterface;
use OpenTelemetry\SDK\Resource\ResourceInfo;
use OpenTelemetry\SDK\Sdk;
final class MeterProvider implements MeterProviderInterface
{
private MetricFactoryInterface $metricFactory;
private ResourceInfo $resource;
private ClockInterface $clock;
private InstrumentationScopeFactoryInterface $instrumentationScopeFactory;
private iterable $metricReaders;
private ViewRegistryInterface $viewRegistry;
private ?ExemplarFilterInterface $exemplarFilter;
private StalenessHandlerFactoryInterface $stalenessHandlerFactory;
private MeterInstruments $instruments;
private MetricRegistryInterface $registry;
private MetricWriterInterface $writer;
private bool $closed = false;
/**
* @param iterable<MetricReaderInterface&MetricSourceRegistryInterface&DefaultAggregationProviderInterface> $metricReaders
*/
public function __construct(
?ContextStorageInterface $contextStorage,
ResourceInfo $resource,
ClockInterface $clock,
AttributesFactoryInterface $attributesFactory,
InstrumentationScopeFactoryInterface $instrumentationScopeFactory,
iterable $metricReaders,
ViewRegistryInterface $viewRegistry,
?ExemplarFilterInterface $exemplarFilter,
StalenessHandlerFactoryInterface $stalenessHandlerFactory,
MetricFactoryInterface $metricFactory = null
) {
$this->metricFactory = $metricFactory ?? new StreamFactory();
$this->resource = $resource;
$this->clock = $clock;
$this->instrumentationScopeFactory = $instrumentationScopeFactory;
$this->metricReaders = $metricReaders;
$this->viewRegistry = $viewRegistry;
$this->exemplarFilter = $exemplarFilter;
$this->stalenessHandlerFactory = $stalenessHandlerFactory;
$this->instruments = new MeterInstruments();
$registry = new MetricRegistry($contextStorage, $attributesFactory, $clock);
$this->registry = $registry;
$this->writer = $registry;
}
public function getMeter(
string $name,
?string $version = null,
?string $schemaUrl = null,
iterable $attributes = []
): MeterInterface {
if ($this->closed || Sdk::isDisabled()) { //@todo create meter provider from factory, and move Sdk::isDisabled() there
return new NoopMeter();
}
return new Meter(
$this->metricFactory,
$this->resource,
$this->clock,
$this->stalenessHandlerFactory,
$this->metricReaders,
$this->viewRegistry,
$this->exemplarFilter,
$this->instruments,
$this->instrumentationScopeFactory->create($name, $version, $schemaUrl, $attributes),
$this->registry,
$this->writer,
);
}
public function shutdown(): bool
{
if ($this->closed) {
return false;
}
$this->closed = true;
$success = true;
foreach ($this->metricReaders as $metricReader) {
if (!$metricReader->shutdown()) {
$success = false;
}
}
return $success;
}
public function forceFlush(): bool
{
if ($this->closed) {
return false;
}
$success = true;
foreach ($this->metricReaders as $metricReader) {
if (!$metricReader->forceFlush()) {
$success = false;
}
}
return $success;
}
public static function builder(): MeterProviderBuilder
{
return new MeterProviderBuilder();
}
}
|
