class ClientManager in Elasticsearch Connector 8.2

Class ClientManager.

Hierarchy

• class \Drupal\elasticsearch_connector\ElasticSearch\ClientManager implements ClientManagerInterface

1 string reference to 'ClientManager'

elasticsearch_connector.services.yml in ./elasticsearch_connector.services.yml

elasticsearch_connector.services.yml

1 service uses ClientManager

elasticsearch_connector.client_manager in ./elasticsearch_connector.services.yml

Drupal\elasticsearch_connector\ElasticSearch\ClientManager

File

src/ElasticSearch/ClientManager.php, line 12

Namespace

Drupal\elasticsearch_connector\ElasticSearch

class ClientManager implements ClientManagerInterface {

  /** @var \nodespark\DESConnector\ClientInterface[] */
  protected $clients = [];

  /**
   * @var ModuleHandlerInterface
   */
  protected $moduleHandler;

  /**
   * The class that implements
   * \nodespark\DESConnector\ClientFactoryInterface.
   *
   * @var string
   */
  protected $clientManagerFactory;

  /**
   * ConnectorManager constructor.
   *
   * @param ModuleHandlerInterface $module_handler
   */
  public function __construct(ModuleHandlerInterface $module_handler, ClientFactoryInterface $clientManagerFactory) {
    $this->moduleHandler = $module_handler;
    $this->clientManagerFactory = $clientManagerFactory;
  }

  /**
   * Get the Elasticsearch client required by the functionality.
   *
   * @param Cluster $cluster
   *
   * @return \nodespark\DESConnector\ClientInterface
   *
   * @throws \Exception
   */
  public function getClientForCluster(Cluster $cluster) {
    $hosts = [
      [
        'url' => $cluster->url,
        'options' => $cluster->options,
      ],
    ];
    $hash = json_encode($hosts);
    if (!isset($this->clients[$hash])) {
      $options = array(
        'hosts' => array(
          $cluster
            ->getRawUrl(),
        ),
        'options' => array(),
        'curl' => array(),
      );
      if ($cluster->options['use_authentication']) {
        $options['auth'] = [
          $cluster->url => [
            'username' => $cluster->options['username'],
            'password' => $cluster->options['password'],
            'method' => $cluster->options['authentication_type'],
          ],
        ];
      }
      $this->moduleHandler
        ->alter('elasticsearch_connector_load_library_options', $options);
      $this->clients[$hash] = $this->clientManagerFactory
        ->create($options);
    }
    return $this->clients[$hash];
  }

}

Members

Name	Modifiers	Type	Description	Overrides
ClientManager::$clientManagerFactory	protected	property	The class that implements \nodespark\DESConnector\ClientFactoryInterface.
ClientManager::$clients	protected	property	@var \nodespark\DESConnector\ClientInterface[]
ClientManager::$moduleHandler	protected	property
ClientManager::getClientForCluster	public	function	Get the Elasticsearch client required by the functionality. Overrides ClientManagerInterface::getClientForCluster
ClientManager::__construct	public	function	ConnectorManager constructor. Overrides ClientManagerInterface::__construct