allow multiple endpoints as dsn to avoid downtime if single node fail…

…s. (new config `hosts`)
valantic · Mar 18, 2024 · cd91fb6 · cd91fb6
1 parent d3c07c3
commit cd91fb6
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/src/DependencyInjection/Configuration.php b/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()

diff --git a/src/Repository/ConfigurationRepository.php b/src/Repository/ConfigurationRepository.php
@@ -15,8 +15,11 @@ public function __construct(
         private readonly ContainerBagInterface $containerBag,
     ) {}
 
-    public function getClientDsn(): string
+    public function getClientDsn(): string|array
     {
+        if (!empty($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'];
     }