summaryrefslogtreecommitdiff
path: root/vendor/open-telemetry/sdk/Metrics/Aggregation/SumAggregation.php
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/open-telemetry/sdk/Metrics/Aggregation/SumAggregation.php')
-rw-r--r--vendor/open-telemetry/sdk/Metrics/Aggregation/SumAggregation.php91
1 files changed, 91 insertions, 0 deletions
diff --git a/vendor/open-telemetry/sdk/Metrics/Aggregation/SumAggregation.php b/vendor/open-telemetry/sdk/Metrics/Aggregation/SumAggregation.php
new file mode 100644
index 000000000..dc317ce73
--- /dev/null
+++ b/vendor/open-telemetry/sdk/Metrics/Aggregation/SumAggregation.php
@@ -0,0 +1,91 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\SDK\Metrics\Aggregation;
+
+use OpenTelemetry\Context\ContextInterface;
+use OpenTelemetry\SDK\Common\Attribute\AttributesInterface;
+use OpenTelemetry\SDK\Metrics\AggregationInterface;
+use OpenTelemetry\SDK\Metrics\Data;
+
+/**
+ * @implements AggregationInterface<SumSummary>
+ */
+final class SumAggregation implements AggregationInterface
+{
+ private bool $monotonic;
+
+ public function __construct(bool $monotonic = false)
+ {
+ $this->monotonic = $monotonic;
+ }
+
+ public function initialize(): SumSummary
+ {
+ return new SumSummary(0);
+ }
+
+ /**
+ * @param SumSummary $summary
+ */
+ public function record($summary, $value, AttributesInterface $attributes, ContextInterface $context, int $timestamp): void
+ {
+ $summary->value += $value;
+ }
+
+ /**
+ * @param SumSummary $left
+ * @param SumSummary $right
+ */
+ public function merge($left, $right): SumSummary
+ {
+ $sum = $left->value + $right->value;
+
+ return new SumSummary(
+ $sum,
+ );
+ }
+
+ /**
+ * @param SumSummary $left
+ * @param SumSummary $right
+ */
+ public function diff($left, $right): SumSummary
+ {
+ $sum = -$left->value + $right->value;
+
+ return new SumSummary(
+ $sum,
+ );
+ }
+
+ /**
+ * @param array<SumSummary> $summaries
+ */
+ public function toData(
+ array $attributes,
+ array $summaries,
+ array $exemplars,
+ int $startTimestamp,
+ int $timestamp,
+ $temporality
+ ): Data\Sum {
+ $dataPoints = [];
+ foreach ($attributes as $key => $dataPointAttributes) {
+ $dataPoints[] = new Data\NumberDataPoint(
+ $summaries[$key]->value,
+ $dataPointAttributes,
+ $startTimestamp,
+ $timestamp,
+ $exemplars[$key] ?? [],
+ );
+ }
+
+ return new Data\Sum(
+ $dataPoints,
+ $temporality,
+ $this->monotonic,
+ );
+ }
+}