LoggerExporter.php

<?php

declare (strict_types=1);
namespace OpenTelemetry\SDK\Trace\SpanExporter;

use OpenTelemetry\SDK\Trace\Behavior\LoggerAwareTrait;
use OpenTelemetry\SDK\Trace\Behavior\SpanExporterTrait;
use OpenTelemetry\SDK\Trace\Behavior\UsesSpanConverterTrait;
use OpenTelemetry\SDK\Trace\SpanConverterInterface;
use OpenTelemetry\SDK\Trace\SpanExporterInterface;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerInterface;
use Psr\Log\LogLevel;
use Psr\Log\NullLogger;
use Throwable;
class LoggerExporter implements SpanExporterInterface, LoggerAwareInterface {
    use SpanExporterTrait;
    use UsesSpanConverterTrait;
    use LoggerAwareTrait;
    public const GRANULARITY_AGGREGATE = 1;
    public const GRANULARITY_SPAN = 2;
    private string $serviceName;
    private int $granularity = self::GRANULARITY_AGGREGATE;
    public function __construct(string $serviceName, ?LoggerInterface $logger = null, ?string $defaultLogLevel = LogLevel::DEBUG, ?SpanConverterInterface $converter = null, int $granularity = 1) {
        $this->setServiceName($serviceName);
        $this->setLogger($logger ?? new NullLogger());
        $this->setDefaultLogLevel($defaultLogLevel ?? LogLevel::DEBUG);
        $this->setSpanConverter($converter ?? new FriendlySpanConverter());
        $this->setGranularity($granularity);
    }
    
    /** @inheritDoc */
    public function doExport(iterable $spans) : bool {
        try {
            $this->doLog($spans);
        } catch (Throwable) {
            return false;
        }
        return true;
    }
    private function setServiceName(string $serviceName) : void {
        $this->serviceName = $serviceName;
    }
    public function setGranularity(int $granularity) : void {
        $this->granularity = $granularity === self::GRANULARITY_SPAN ? self::GRANULARITY_SPAN : self::GRANULARITY_AGGREGATE;
    }
    private function doLog(iterable $spans) : void {
        if ($this->granularity === self::GRANULARITY_AGGREGATE) {
            $this->log($this->serviceName, $this->getSpanConverter()
                ->convert($spans));
            return;
        }
        foreach ($spans as $span) {
            $this->log($this->serviceName, $this->getSpanConverter()
                ->convert([
                $span,
            ]));
        }
    }

}