allow multiple endpoints as dsn to avoid downtime if single node fails. (new config hosts)

Author: rliebi

src/DependencyInjection/Configuration.php

@@ -16,6 +16,7 @@ public function getConfigTreeBuilder()
             ->children()
             ->arrayNode('client')
             ->children()
+            ->arrayNode('hosts')->defaultValue([])->info('An array of DSN to connect to the Elasticsearch cluster.')->scalarPrototype()->end()->end()
             ->scalarNode('dsn')->defaultValue('http://localhost:9200')->info('The DSN to connect to the Elasticsearch cluster.')->end()
             ->booleanNode('should_add_sentry_breadcrumbs')->defaultFalse()->info('If true, breadcrumbs are added to Sentry for every request made to Elasticsearch via Elastica.')->end()
             ->end()

src/Repository/ConfigurationRepository.php

@@ -4,6 +4,8 @@
 
 namespace Valantic\ElasticaBridgeBundle\Repository;
 
+use Psr\Container\ContainerExceptionInterface;
+use Psr\Container\NotFoundExceptionInterface;
 use Symfony\Component\DependencyInjection\ParameterBag\ContainerBagInterface;
 
 /**
@@ -15,8 +17,18 @@ public function __construct(
         private readonly ContainerBagInterface $containerBag,
     ) {}
 
-    public function getClientDsn(): string
+    /**
+     * @throws ContainerExceptionInterface
+     * @throws NotFoundExceptionInterface
+     *
+     * @return string|array<string>
+     */
+    public function getClientDsn(): string|array
     {
+        if ($this->containerBag->get('valantic_elastica_bridge')['client']['hosts'] !== []) {
+            return $this->containerBag->get('valantic_elastica_bridge')['client']['hosts'];
+        }
+
         return $this->containerBag->get('valantic_elastica_bridge')['client']['dsn'];
     }