function elasticsearch_connector_get_client_by_id in Elasticsearch Connector 7.5

Same name and namespace in other branches

1. 7 elasticsearch_connector.module \elasticsearch_connector_get_client_by_id()
2. 7.2 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

27 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_statistics_access_log in modules/elasticsearch_connector_statistics/elasticsearch_connector_statistics.admin.inc

Page callback: Gathers page access statistics suitable for rendering.

elasticsearch_connector_statistics_delete_node_logs in modules/elasticsearch_connector_statistics/elasticsearch_connector_statistics.module

Delete the node logs based on NID.

elasticsearch_connector_statistics_log_statistics in modules/elasticsearch_connector_statistics/elasticsearch_connector_statistics.module

Check if everything is OK and log the statistics.

elasticsearch_connector_statistics_recent_hits in modules/elasticsearch_connector_statistics/elasticsearch_connector_statistics.admin.inc

Page callback: Displays the "recent hits" page.

... 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;
}