wip

src/DependencyInjection/Configuration.php

@@ -15,6 +15,8 @@
 use FriendsOfOpenTelemetry\OpenTelemetryBundle\OpenTelemetry\Trace\TracerProvider\TraceProviderEnum;
 use FriendsOfOpenTelemetry\OpenTelemetryBundle\OpenTelemetry\Trace\TraceSamplerEnum;
 use Monolog\Level;
+use OpenTelemetry\API\Common\Time\SystemClock;
+use OpenTelemetry\SDK\Logs\Processor\BatchLogRecordProcessor;
 use Symfony\Component\Config\Definition\Builder\ArrayNodeDefinition;
 use Symfony\Component\Config\Definition\Builder\TreeBuilder;
 use Symfony\Component\Config\Definition\ConfigurationInterface;
@@ -500,8 +502,19 @@ private function getLogsProcessorsNode(): ArrayNodeDefinition
                         ->scalarPrototype()
                         ->end()
                     ->end()
+                    ->arrayNode('batch')
+                        ->info('Required if processor type is batch')
+                        ->children()
+                            ->scalarNode('clock')->defaultValue(SystemClock::class)->end()
+                            ->integerNode('max_queue_size')->isRequired()->defaultValue(BatchLogRecordProcessor::DEFAULT_MAX_QUEUE_SIZE)->end()
+                            ->integerNode('schedule_delay')->isRequired()->defaultValue(BatchLogRecordProcessor::DEFAULT_SCHEDULE_DELAY)->end()
+                            ->integerNode('export_timeout')->isRequired()->defaultValue(BatchLogRecordProcessor::DEFAULT_EXPORT_TIMEOUT)->end()
+                            ->integerNode('max_export_batch_size')->isRequired()->defaultValue(BatchLogRecordProcessor::DEFAULT_MAX_EXPORT_BATCH_SIZE)->end()
+                            ->scalarNode('provider')->isRequired()->end()
+                        ->end()
+                    ->end()
                     ->scalarNode('exporter')
-                        ->info('Required if processor type is simple')
+                        ->info('Required if processor type is simple or batch')
                         ->cannotBeEmpty()
                     ->end()
                 ->end()

src/OpenTelemetry/Log/LogProcessor/BatchLogProcessorFactory.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace FriendsOfOpenTelemetry\OpenTelemetryBundle\OpenTelemetry\Log\LogProcessor;
+
+use FriendsOfOpenTelemetry\OpenTelemetryBundle\OpenTelemetry\Log\LogProcessor\LogProcessorFactoryInterface;
+use OpenTelemetry\SDK\Logs\LogRecordExporterInterface;
+use OpenTelemetry\SDK\Logs\LogRecordProcessorInterface;
+use OpenTelemetry\SDK\Logs\Processor\BatchLogRecordProcessor;
+
+final class BatchLogProcessorFactory implements LogProcessorFactoryInterface
+{
+    public function createProcessor(array $processors = [], ?LogRecordExporterInterface $exporter = null): LogRecordProcessorInterface
+    {
+        return new BatchLogRecordProcessor();
+    }
+}

src/OpenTelemetry/Log/LogProcessor/LogProcessorEnum.php

@@ -4,6 +4,7 @@
 
 enum LogProcessorEnum: string
 {
+    case Batch = 'batch';
     case Multi = 'multi';
     case Noop = 'noop';
     case Simple = 'simple';

src/Resources/config/services_logs.php

@@ -10,6 +10,7 @@
 use FriendsOfOpenTelemetry\OpenTelemetryBundle\OpenTelemetry\Log\LoggerProvider\DefaultLoggerProviderFactory;
 use FriendsOfOpenTelemetry\OpenTelemetryBundle\OpenTelemetry\Log\LoggerProvider\NoopLoggerProviderFactory;
 use FriendsOfOpenTelemetry\OpenTelemetryBundle\OpenTelemetry\Log\LogProcessor\AbstractLogProcessorFactory;
+use FriendsOfOpenTelemetry\OpenTelemetryBundle\OpenTelemetry\Log\LogProcessor\BatchLogProcessorFactory;
 use FriendsOfOpenTelemetry\OpenTelemetryBundle\OpenTelemetry\Log\LogProcessor\MultiLogProcessorFactory;
 use FriendsOfOpenTelemetry\OpenTelemetryBundle\OpenTelemetry\Log\LogProcessor\NoopLogProcessorFactory;
 use FriendsOfOpenTelemetry\OpenTelemetryBundle\OpenTelemetry\Log\LogProcessor\SimpleLogProcessorFactory;
@@ -71,6 +72,9 @@
             ])
             ->tag('monolog.logger', ['channel' => 'open_telemetry'])
 
+        ->set('open_telemetry.logs.processor_factory.batch', BatchLogProcessorFactory::class)
+            ->parent('open_telemetry.logs.processor_factory.abstract')
+
         ->set('open_telemetry.logs.processor_factory.multi', MultiLogProcessorFactory::class)
             ->parent('open_telemetry.logs.processor_factory.abstract')