MultiObserver.php

<?php

declare (strict_types=1);
namespace OpenTelemetry\SDK\Metrics\MetricRegistry;

use OpenTelemetry\API\Metrics\ObserverInterface;
use OpenTelemetry\Context\Context;
use OpenTelemetry\SDK\Common\Attribute\AttributesFactoryInterface;
use OpenTelemetry\SDK\Metrics\Stream\WritableMetricStreamInterface;

/**
 * @internal
 */
final class MultiObserver implements ObserverInterface {
    
    /** @var list<WritableMetricStreamInterface>  */
    public array $writers = [];
    public function __construct(AttributesFactoryInterface $attributesFactory, int $timestamp) {
    }
    public function observe($amount, iterable $attributes = []) : void {
        $context = Context::getRoot();
        $attributes = $this->attributesFactory
            ->builder($attributes)
            ->build();
        foreach ($this->writers as $writer) {
            $writer->record($amount, $attributes, $context, $this->timestamp);
        }
    }

}