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
|
<?php
declare(strict_types=1);
namespace OpenTelemetry\SDK\Metrics\Exemplar;
use function array_fill;
use function assert;
use function count;
use OpenTelemetry\API\Trace\Span;
use OpenTelemetry\Context\ContextInterface;
use OpenTelemetry\SDK\Common\Attribute\Attributes;
use OpenTelemetry\SDK\Common\Attribute\AttributesInterface;
use OpenTelemetry\SDK\Metrics\Data\Exemplar;
/**
* @internal
*/
final class BucketStorage
{
/** @var array<int, BucketEntry|null> */
private array $buckets;
public function __construct(int $size = 0)
{
$this->buckets = array_fill(0, $size, null);
}
/**
* @param int|string $index
* @param float|int $value
*/
public function store(int $bucket, $index, $value, AttributesInterface $attributes, ContextInterface $context, int $timestamp): void
{
assert($bucket <= count($this->buckets));
$exemplar = $this->buckets[$bucket] ??= new BucketEntry();
$exemplar->index = $index;
$exemplar->value = $value;
$exemplar->timestamp = $timestamp;
$exemplar->attributes = $attributes;
if (($spanContext = Span::fromContext($context)->getContext())->isValid()) {
$exemplar->traceId = $spanContext->getTraceId();
$exemplar->spanId = $spanContext->getSpanId();
} else {
$exemplar->traceId = null;
$exemplar->spanId = null;
}
}
/**
* @param array<AttributesInterface> $dataPointAttributes
* @return array<Exemplar>
*/
public function collect(array $dataPointAttributes): array
{
$exemplars = [];
foreach ($this->buckets as $index => &$exemplar) {
if (!$exemplar) {
continue;
}
$exemplars[$index] = new Exemplar(
$exemplar->index,
$exemplar->value,
$exemplar->timestamp,
$this->filterExemplarAttributes(
$dataPointAttributes[$exemplar->index],
$exemplar->attributes,
),
$exemplar->traceId,
$exemplar->spanId,
);
$exemplar = null;
}
return $exemplars;
}
private function filterExemplarAttributes(AttributesInterface $dataPointAttributes, AttributesInterface $exemplarAttributes): AttributesInterface
{
$attributes = [];
foreach ($exemplarAttributes as $key => $value) {
if ($dataPointAttributes->get($key) === null) {
$attributes[$key] = $value;
}
}
return new Attributes($attributes, $exemplarAttributes->getDroppedAttributesCount());
}
}
|
