summaryrefslogtreecommitdiff
path: root/vendor/open-telemetry/sdk/Metrics/Aggregation
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/open-telemetry/sdk/Metrics/Aggregation')
-rw-r--r--vendor/open-telemetry/sdk/Metrics/Aggregation/ExplicitBucketHistogramAggregation.php167
-rw-r--r--vendor/open-telemetry/sdk/Metrics/Aggregation/ExplicitBucketHistogramSummary.php40
-rw-r--r--vendor/open-telemetry/sdk/Metrics/Aggregation/LastValueAggregation.php81
-rw-r--r--vendor/open-telemetry/sdk/Metrics/Aggregation/LastValueSummary.php22
-rw-r--r--vendor/open-telemetry/sdk/Metrics/Aggregation/SumAggregation.php91
-rw-r--r--vendor/open-telemetry/sdk/Metrics/Aggregation/SumSummary.php20
6 files changed, 421 insertions, 0 deletions
diff --git a/vendor/open-telemetry/sdk/Metrics/Aggregation/ExplicitBucketHistogramAggregation.php b/vendor/open-telemetry/sdk/Metrics/Aggregation/ExplicitBucketHistogramAggregation.php
new file mode 100644
index 000000000..d68ecd830
--- /dev/null
+++ b/vendor/open-telemetry/sdk/Metrics/Aggregation/ExplicitBucketHistogramAggregation.php
@@ -0,0 +1,167 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\SDK\Metrics\Aggregation;
+
+use function array_fill;
+use function count;
+use const INF;
+use const NAN;
+use OpenTelemetry\Context\ContextInterface;
+use OpenTelemetry\SDK\Common\Attribute\AttributesInterface;
+use OpenTelemetry\SDK\Metrics\AggregationInterface;
+use OpenTelemetry\SDK\Metrics\Data;
+
+/**
+ * @implements AggregationInterface<ExplicitBucketHistogramSummary>
+ */
+final class ExplicitBucketHistogramAggregation implements AggregationInterface
+{
+ /**
+ * @var list<float|int>
+ * @readonly
+ */
+ public array $boundaries;
+
+ /**
+ * @param list<float|int> $boundaries strictly ascending histogram bucket boundaries
+ */
+ public function __construct(array $boundaries)
+ {
+ $this->boundaries = $boundaries;
+ }
+
+ public function initialize(): ExplicitBucketHistogramSummary
+ {
+ return new ExplicitBucketHistogramSummary(
+ 0,
+ 0,
+ +INF,
+ -INF,
+ array_fill(0, count($this->boundaries) + 1, 0),
+ );
+ }
+
+ /**
+ * @param ExplicitBucketHistogramSummary $summary
+ */
+ public function record($summary, $value, AttributesInterface $attributes, ContextInterface $context, int $timestamp): void
+ {
+ $boundariesCount = count($this->boundaries);
+ for ($i = 0; $i < $boundariesCount && $this->boundaries[$i] < $value; $i++) {
+ }
+ $summary->count++;
+ $summary->sum += $value;
+ $summary->min = self::min($value, $summary->min);
+ $summary->max = self::max($value, $summary->max);
+ $summary->buckets[$i]++;
+ }
+
+ /**
+ * @param ExplicitBucketHistogramSummary $left
+ * @param ExplicitBucketHistogramSummary $right
+ */
+ public function merge($left, $right): ExplicitBucketHistogramSummary
+ {
+ $count = $left->count + $right->count;
+ $sum = $left->sum + $right->sum;
+ $min = self::min($left->min, $right->min);
+ $max = self::max($left->max, $right->max);
+ $buckets = $right->buckets;
+ foreach ($left->buckets as $i => $bucketCount) {
+ $buckets[$i] += $bucketCount;
+ }
+
+ return new ExplicitBucketHistogramSummary(
+ $count,
+ $sum,
+ $min,
+ $max,
+ $buckets,
+ );
+ }
+
+ /**
+ * @param ExplicitBucketHistogramSummary $left
+ * @param ExplicitBucketHistogramSummary $right
+ */
+ public function diff($left, $right): ExplicitBucketHistogramSummary
+ {
+ $count = -$left->count + $right->count;
+ $sum = -$left->sum + $right->sum;
+ $min = $left->min > $right->min ? $right->min : NAN;
+ $max = $left->max < $right->max ? $right->max : NAN;
+ $buckets = $right->buckets;
+ foreach ($left->buckets as $i => $bucketCount) {
+ $buckets[$i] -= $bucketCount;
+ }
+
+ return new ExplicitBucketHistogramSummary(
+ $count,
+ $sum,
+ $min,
+ $max,
+ $buckets,
+ );
+ }
+
+ /**
+ * @param array<ExplicitBucketHistogramSummary> $summaries
+ */
+ public function toData(
+ array $attributes,
+ array $summaries,
+ array $exemplars,
+ int $startTimestamp,
+ int $timestamp,
+ $temporality
+ ): Data\Histogram {
+ $dataPoints = [];
+ foreach ($attributes as $key => $dataPointAttributes) {
+ if ($summaries[$key]->count === 0) {
+ continue;
+ }
+
+ $dataPoints[] = new Data\HistogramDataPoint(
+ $summaries[$key]->count,
+ $summaries[$key]->sum,
+ $summaries[$key]->min,
+ $summaries[$key]->max,
+ $summaries[$key]->buckets,
+ $this->boundaries,
+ $dataPointAttributes,
+ $startTimestamp,
+ $timestamp,
+ $exemplars[$key] ?? [],
+ );
+ }
+
+ return new Data\Histogram(
+ $dataPoints,
+ $temporality,
+ );
+ }
+
+ /**
+ * @param float|int $left
+ * @param float|int $right
+ * @return float|int
+ */
+ private static function min($left, $right)
+ {
+ /** @noinspection PhpConditionAlreadyCheckedInspection */
+ return $left <= $right ? $left : ($right <= $left ? $right : NAN);
+ }
+
+ /**
+ * @param float|int $left
+ * @param float|int $right
+ * @return float|int
+ */
+ private static function max($left, $right)
+ {
+ /** @noinspection PhpConditionAlreadyCheckedInspection */
+ return $left >= $right ? $left : ($right >= $left ? $right : NAN);
+ }
+}
diff --git a/vendor/open-telemetry/sdk/Metrics/Aggregation/ExplicitBucketHistogramSummary.php b/vendor/open-telemetry/sdk/Metrics/Aggregation/ExplicitBucketHistogramSummary.php
new file mode 100644
index 000000000..1878a34a0
--- /dev/null
+++ b/vendor/open-telemetry/sdk/Metrics/Aggregation/ExplicitBucketHistogramSummary.php
@@ -0,0 +1,40 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\SDK\Metrics\Aggregation;
+
+final class ExplicitBucketHistogramSummary
+{
+ public int $count;
+ /**
+ * @var float|int
+ */
+ public $sum;
+ /**
+ * @var float|int
+ */
+ public $min;
+ /**
+ * @var float|int
+ */
+ public $max;
+ /**
+ * @var int[]
+ */
+ public array $buckets;
+ /**
+ * @param float|int $sum
+ * @param float|int $min
+ * @param float|int $max
+ * @param int[] $buckets
+ */
+ public function __construct(int $count, $sum, $min, $max, array $buckets)
+ {
+ $this->count = $count;
+ $this->sum = $sum;
+ $this->min = $min;
+ $this->max = $max;
+ $this->buckets = $buckets;
+ }
+}
diff --git a/vendor/open-telemetry/sdk/Metrics/Aggregation/LastValueAggregation.php b/vendor/open-telemetry/sdk/Metrics/Aggregation/LastValueAggregation.php
new file mode 100644
index 000000000..aff04e315
--- /dev/null
+++ b/vendor/open-telemetry/sdk/Metrics/Aggregation/LastValueAggregation.php
@@ -0,0 +1,81 @@
+<?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<LastValueSummary>
+ */
+final class LastValueAggregation implements AggregationInterface
+{
+ public function initialize(): LastValueSummary
+ {
+ return new LastValueSummary(null, 0);
+ }
+
+ /**
+ * @param LastValueSummary $summary
+ */
+ public function record($summary, $value, AttributesInterface $attributes, ContextInterface $context, int $timestamp): void
+ {
+ if ($summary->value === null || $timestamp >= $summary->timestamp) {
+ $summary->value = $value;
+ $summary->timestamp = $timestamp;
+ }
+ }
+
+ /**
+ * @param LastValueSummary $left
+ * @param LastValueSummary $right
+ */
+ public function merge($left, $right): LastValueSummary
+ {
+ return $right->timestamp >= $left->timestamp ? $right : $left;
+ }
+
+ /**
+ * @param LastValueSummary $left
+ * @param LastValueSummary $right
+ */
+ public function diff($left, $right): LastValueSummary
+ {
+ return $right->timestamp >= $left->timestamp ? $right : $left;
+ }
+
+ /**
+ * @param array<LastValueSummary> $summaries
+ */
+ public function toData(
+ array $attributes,
+ array $summaries,
+ array $exemplars,
+ int $startTimestamp,
+ int $timestamp,
+ $temporality
+ ): Data\Gauge {
+ $dataPoints = [];
+ foreach ($attributes as $key => $dataPointAttributes) {
+ if ($summaries[$key]->value === null) {
+ continue;
+ }
+
+ $dataPoints[] = new Data\NumberDataPoint(
+ $summaries[$key]->value,
+ $dataPointAttributes,
+ $startTimestamp,
+ $timestamp,
+ $exemplars[$key] ?? [],
+ );
+ }
+
+ return new Data\Gauge(
+ $dataPoints,
+ );
+ }
+}
diff --git a/vendor/open-telemetry/sdk/Metrics/Aggregation/LastValueSummary.php b/vendor/open-telemetry/sdk/Metrics/Aggregation/LastValueSummary.php
new file mode 100644
index 000000000..6cdb5ac9f
--- /dev/null
+++ b/vendor/open-telemetry/sdk/Metrics/Aggregation/LastValueSummary.php
@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\SDK\Metrics\Aggregation;
+
+final class LastValueSummary
+{
+ /**
+ * @var float|int|null
+ */
+ public $value;
+ public int $timestamp;
+ /**
+ * @param float|int|null $value
+ */
+ public function __construct($value, int $timestamp)
+ {
+ $this->value = $value;
+ $this->timestamp = $timestamp;
+ }
+}
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,
+ );
+ }
+}
diff --git a/vendor/open-telemetry/sdk/Metrics/Aggregation/SumSummary.php b/vendor/open-telemetry/sdk/Metrics/Aggregation/SumSummary.php
new file mode 100644
index 000000000..9b257193c
--- /dev/null
+++ b/vendor/open-telemetry/sdk/Metrics/Aggregation/SumSummary.php
@@ -0,0 +1,20 @@
+<?php
+
+declare(strict_types=1);
+
+namespace OpenTelemetry\SDK\Metrics\Aggregation;
+
+final class SumSummary
+{
+ /**
+ * @var float|int
+ */
+ public $value;
+ /**
+ * @param float|int $value
+ */
+ public function __construct($value)
+ {
+ $this->value = $value;
+ }
+}