function elasticsearch_connector_get_client_by_id in Elasticsearch Connector 7.2

Same name and namespace in other branches

1. 7.5 elasticsearch_connector.module \elasticsearch_connector_get_client_by_id()
2. 7 elasticsearch_connector.module \elasticsearch_connector_get_client_by_id()

Return the cluster object based on Cluster ID.

Parameters

string $cluster_id:

boolean:

Return value

\nodespark\DESConnector\ClientInterface $client

33 calls to elasticsearch_connector_get_client_by_id()

elasticsearch_connector_get_indices_options in ./elasticsearch_connector.module

Get the indeces based on cluster id.

elasticsearch_connector_sequence_get_next in modules/elasticsearch_connector_sequence/elasticsearch_connector_sequence.module

Generate a sequence/autoincrement id.

elasticsearch_connector_sequence_requirements in modules/elasticsearch_connector_sequence/elasticsearch_connector_sequence.install

Implements hook_requirements().

elasticsearch_connector_sequence_submit in modules/elasticsearch_connector_sequence/elasticsearch_connector_sequence.admin.inc

Handle the submit of settings form. It is used for additional actions if necessary.

elasticsearch_connector_sequence_uninstall in modules/elasticsearch_connector_sequence/elasticsearch_connector_sequence.install

Implements hook_uninstall().

... See full list

File

./elasticsearch_connector.module, line 763

This module provide an interface to connecting to the elasticsearch cluster and implementing the official Elasticsearch library.

Code

function elasticsearch_connector_get_client_by_id($cluster_id = NULL, $default_fallback = NULL) {
  if (!isset($cluster_id) && !empty($default_fallback)) {
    $cluster_id = elasticsearch_connector_get_default_connector();
  }
  if (!empty($cluster_id)) {
    $client = FALSE;
    $cluster = elasticsearch_connector_cluster_load($cluster_id);
    if ($cluster) {
      $client = elasticsearch_connector_load_library($cluster);
    }
  }
  return $client;
}