function elasticsearch_connector_get_cluster_info in Elasticsearch Connector 7

Same name and namespace in other branches

1. 7.5 elasticsearch_connector.module \elasticsearch_connector_get_cluster_info()
2. 7.2 elasticsearch_connector.module \elasticsearch_connector_get_cluster_info()

Return cluster info.

Parameters

object: $cluster - The cluster object.

boolean: $enable_messages - Set error message if the get status function throw exception.

Return value

return array Return the info for the cluster: 'info' 'state' 'health'

7 calls to elasticsearch_connector_get_cluster_info()

elasticsearch_connector_cluster_indices in ./elasticsearch_connector.admin.inc

Elasticsearch Connector display all indices in cluster.

elasticsearch_connector_cluster_indices_aliases in ./elasticsearch_connector.admin.inc

List all aliases for an index.

elasticsearch_connector_edit_cluster_form_info in ./elasticsearch_connector.admin.inc

Build the dynamic cluster status.

elasticsearch_connector_edit_cluster_validate in ./elasticsearch_connector.admin.inc

Handle the cluster add/edit validations.

elasticsearch_connector_info_cluster in ./elasticsearch_connector.admin.inc

... See full list

File

./elasticsearch_connector.module, line 875

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

Code

function elasticsearch_connector_get_cluster_info($cluster, $enable_messages = FALSE) {
  $result = FALSE;
  $client = elasticsearch_connector_load_library($cluster);
  if (!empty($client)) {
    try {
      $info = $client
        ->info();
      $result['client'] = $client;
      $result['info'] = $result['state'] = $result['health'] = $result['stats'] = array();
      if (elasticsearch_connector_check_status($info)) {
        $result['info'] = $info;
        $result['state'] = $client
          ->cluster()
          ->state();
        $result['health'] = $client
          ->cluster()
          ->health();
        $result['stats'] = $client
          ->nodes()
          ->stats();
      }
    } catch (Exception $e) {
      if ($enable_messages) {
        drupal_set_message($e
          ->getMessage(), 'error');
      }
    }
  }
  return $result;
}