function SynchronousMetricStream::collect

Overrides MetricStreamInterface::collect

File

vendor/open-telemetry/sdk/Metrics/Stream/SynchronousMetricStream.php, line 99

Class

SynchronousMetricStream

@internal @phan-file-suppress PhanUndeclaredTypeParameter, PhanUndeclaredTypeProperty

Namespace

OpenTelemetry\SDK\Metrics\Stream

Code

public function collect(int $reader) : DataInterface {
    $cumulative = ($this->cumulative >> $reader & 1) != 0;
    $metric = $this->delta
        ->collect($reader, $cumulative) ?? new Metric([], [], $this->timestamp);
    $temporality = $cumulative ? Temporality::CUMULATIVE : Temporality::DELTA;
    return $this->aggregation
        ->toData($metric->attributes, $metric->summaries, Exemplar::groupByIndex($metric->exemplars), $metric->timestamp, $this->timestamp, $temporality);
}