74 lines
2.3 KiB
PHP
74 lines
2.3 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
declare(strict_types=1);
|
||
|
|
|
||
|
|
namespace OpenTelemetry\SDK\Metrics\Stream;
|
||
|
|
|
||
|
|
use OpenTelemetry\Context\ContextInterface;
|
||
|
|
use OpenTelemetry\SDK\Common\Attribute\AttributesInterface;
|
||
|
|
use OpenTelemetry\SDK\Metrics\AggregationInterface;
|
||
|
|
use OpenTelemetry\SDK\Metrics\AttributeProcessorInterface;
|
||
|
|
use OpenTelemetry\SDK\Metrics\Exemplar\ExemplarReservoirInterface;
|
||
|
|
use function serialize;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @internal
|
||
|
|
*/
|
||
|
|
final class MetricAggregator implements MetricAggregatorInterface
|
||
|
|
{
|
||
|
|
private ?AttributeProcessorInterface $attributeProcessor;
|
||
|
|
private AggregationInterface $aggregation;
|
||
|
|
private ?ExemplarReservoirInterface $exemplarReservoir;
|
||
|
|
|
||
|
|
/** @var array<AttributesInterface> */
|
||
|
|
private array $attributes = [];
|
||
|
|
private array $summaries = [];
|
||
|
|
|
||
|
|
public function __construct(
|
||
|
|
?AttributeProcessorInterface $attributeProcessor,
|
||
|
|
AggregationInterface $aggregation,
|
||
|
|
?ExemplarReservoirInterface $exemplarReservoir = null
|
||
|
|
) {
|
||
|
|
$this->attributeProcessor = $attributeProcessor;
|
||
|
|
$this->aggregation = $aggregation;
|
||
|
|
$this->exemplarReservoir = $exemplarReservoir;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param float|int $value
|
||
|
|
*/
|
||
|
|
public function record($value, AttributesInterface $attributes, ContextInterface $context, int $timestamp): void
|
||
|
|
{
|
||
|
|
$filteredAttributes = $this->attributeProcessor !== null
|
||
|
|
? $this->attributeProcessor->process($attributes, $context)
|
||
|
|
: $attributes;
|
||
|
|
$raw = $filteredAttributes->toArray();
|
||
|
|
$index = $raw !== [] ? serialize($raw) : 0;
|
||
|
|
$this->attributes[$index] ??= $filteredAttributes;
|
||
|
|
$this->aggregation->record(
|
||
|
|
$this->summaries[$index] ??= $this->aggregation->initialize(),
|
||
|
|
$value,
|
||
|
|
$attributes,
|
||
|
|
$context,
|
||
|
|
$timestamp,
|
||
|
|
);
|
||
|
|
|
||
|
|
if ($this->exemplarReservoir !== null) {
|
||
|
|
$this->exemplarReservoir->offer($index, $value, $attributes, $context, $timestamp);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public function collect(int $timestamp): Metric
|
||
|
|
{
|
||
|
|
$exemplars = $this->exemplarReservoir
|
||
|
|
? $this->exemplarReservoir->collect($this->attributes)
|
||
|
|
: [];
|
||
|
|
$metric = new Metric($this->attributes, $this->summaries, $timestamp, $exemplars);
|
||
|
|
|
||
|
|
$this->attributes = [];
|
||
|
|
$this->summaries = [];
|
||
|
|
|
||
|
|
return $metric;
|
||
|
|
}
|
||
|
|
}
|