View source
<?php
namespace Drupal\elasticsearch_connector\Controller;
use Drupal\Component\Utility\SafeMarkup;
use Drupal\Core\Controller\ControllerBase;
use Drupal\Core\Config\Entity\ConfigEntityBase;
use Drupal\elasticsearch_connector\Entity\Cluster;
class ElasticsearchController extends ControllerBase {
public function page(Cluster $elasticsearch_cluster) {
$render = array(
'view' => array(
'#theme' => 'elasticsearch_cluster',
'#cluster' => $elasticsearch_cluster,
),
);
if ($elasticsearch_cluster->cluster_id) {
$render['form'] = $this
->formBuilder()
->getForm('Drupal\\elasticsearch_connector\\Form\\ClusterForm', $elasticsearch_cluster);
}
return $render;
}
public function pageTitle(Cluster $elasticsearch_cluster) {
return $elasticsearch_cluster
->label();
}
public function getInfo(Cluster $elasticsearch_cluster) {
if ($elasticsearch_cluster
->checkClusterStatus()) {
$es_client = $elasticsearch_cluster
->getClientInstance($elasticsearch_cluster);
$es_node_namespace = $es_client
->getNodesProperties();
$node_stats = $es_node_namespace['stats'];
$total_docs = 0;
$total_size = 0;
$node_rows = array();
if (!empty($node_stats['nodes'])) {
foreach ($node_stats['nodes'] as $node_id => $node_properties) {
$row = array();
$row[] = array(
'data' => $node_properties['name'],
);
$row[] = array(
'data' => $node_properties['indices']['docs']['count'],
);
$row[] = array(
'data' => format_size($node_properties['indices']['store']['size_in_bytes']),
);
$total_docs += $node_properties['indices']['docs']['count'];
$total_size += $node_properties['indices']['store']['size_in_bytes'];
$node_rows[] = $row;
}
}
$cluster_status = $elasticsearch_cluster
->getClusterInfo();
$cluster_statistics_rows = array(
array(
array(
'data' => $cluster_status['health']['number_of_nodes'] . ' ' . t('Nodes'),
),
array(
'data' => $cluster_status['health']['active_shards'] + $cluster_status['health']['unassigned_shards'] . ' ' . t('Total Shards'),
),
array(
'data' => $cluster_status['health']['active_shards'] . ' ' . t('Successful Shards'),
),
array(
'data' => count($cluster_status['state']['metadata']['indices']) . ' ' . t('Indices'),
),
array(
'data' => $total_docs . ' ' . t('Total Documents'),
),
array(
'data' => format_size($total_size) . ' ' . t('Total Size'),
),
),
);
$cluster_health_rows = array();
$cluster_health_mapping = array(
'cluster_name' => t('Cluster name'),
'status' => t('Status'),
'timed_out' => t('Time out'),
'number_of_nodes' => t('Number of nodes'),
'number_of_data_nodes' => t('Number of data nodes'),
'active_primary_shards' => t('Active primary shards'),
'active_shards' => t('Active shards'),
'relocating_shards' => t('Relocating shards'),
'initializing_shards' => t('Initializing shards'),
'unassigned_shards' => t('Unassigned shards'),
'delayed_unassigned_shards' => t('Delayed unassigned shards'),
'number_of_pending_tasks' => t('Number of pending tasks'),
'number_of_in_flight_fetch' => t('Number of in-flight fetch'),
'task_max_waiting_in_queue_millis' => t('Task max waiting in queue millis'),
'active_shards_percent_as_number' => t('Active shards percent as number'),
);
foreach ($cluster_status['health'] as $health_key => $health_value) {
$row = array();
$row[] = array(
'data' => $cluster_health_mapping[$health_key],
);
$row[] = array(
'data' => $health_value === FALSE ? 'False' : $health_value,
);
$cluster_health_rows[] = $row;
}
}
$output['cluster_statistics_wrapper'] = array(
'#type' => 'fieldset',
'#title' => t('Cluster statistics'),
'#collapsible' => TRUE,
'#collapsed' => FALSE,
'#attributes' => array(),
);
$output['cluster_statistics_wrapper']['nodes'] = array(
'#theme' => 'table',
'#header' => array(
array(
'data' => t('Node name'),
),
array(
'data' => t('Documents'),
),
array(
'data' => t('Size'),
),
),
'#rows' => $node_rows,
'#attributes' => array(),
);
$output['cluster_statistics_wrapper']['cluster_statistics'] = array(
'#theme' => 'table',
'#header' => array(
array(
'data' => t('Total'),
'colspan' => 6,
),
),
'#rows' => $cluster_statistics_rows,
'#attributes' => array(
'class' => array(
'admin-elasticsearch-statistics',
),
),
);
$output['cluster_health'] = array(
'#theme' => 'table',
'#header' => array(
array(
'data' => t('Cluster Health'),
'colspan' => 2,
),
),
'#rows' => $cluster_health_rows,
'#attributes' => array(
'class' => array(
'admin-elasticsearch-health',
),
),
);
return $output;
}
}