Multiple connections support

README.md

@@ -301,6 +301,15 @@ You can delete an alias by its name:
 Index::deleteAlias('my-index', 'my-alias');
 ```
 
+#### Multiple Connections
+
+You can configure multiple connections to Elasticsearch in the [client's configuration file](https://github.com/babenkoivan/elastic-client/tree/master#configuration),
+and then use a different connection for every operation:
+
+```php
+Index::connection('my-connection')->drop('my-index');
+```
+
 #### More
 
 Finally, you are free to inject `Elastic\Elasticsearch\Client` in the migration constructor and execute any supported by client actions.

src/Adapters/IndexManagerAdapter.php

@@ -176,4 +176,11 @@ public function deleteAlias(string $indexName, string $aliasName): IndexManagerI
 
         return $this;
     }
+
+    public function connection(string $connection): IndexManagerInterface
+    {
+        $self = clone $this;
+        $self->indexManager = $self->indexManager->connection($connection);
+        return $self;
+    }
 }

src/IndexManagerInterface.php

@@ -27,4 +27,6 @@ public function pushSettingsRaw(string $indexName, array $settings): self;
     public function drop(string $indexName): self;
 
     public function dropIfExists(string $indexName): self;
+
+    public function connection(string $connection): self;
 }

tests/Integration/Adapters/IndexManagerAdapterTest.php

@@ -375,6 +375,18 @@ public function test_alias_can_be_deleted(string $aliasNamePrefix): void
         $this->indexManagerAdapter->deleteAlias($indexName, $aliasName);
     }
 
+    public function test_connection_can_be_changed(): void
+    {
+        $connection = 'test';
+
+        $this->indexManagerMock
+            ->expects($this->once())
+            ->method('connection')
+            ->with($connection);
+
+        $this->indexManagerAdapter->connection($connection);
+    }
+
     public function prefixProvider(): array
     {
         return [