Add overview and shards

These rows are pretty close to complete. This starts the work on documents while the sizing is still off.

Signed-off-by: Joe Adams <[email protected]>

Author: sysadmind

elasticsearch_mixin/dashboards/cluster.libsonnet

@@ -1,7 +1,10 @@
 local g = import 'g.libsonnet';
 
 local dashboard = g.dashboard;
+local row = g.panel.row;
 
+local panels = import './panels.libsonnet';
+local queries = import './queries.libsonnet';
 local variables = import './variables.libsonnet';
 
 {
@@ -13,8 +16,32 @@ local variables = import './variables.libsonnet';
       + dashboard.time.withFrom(value='now-1h')
       + dashboard.graphTooltip.withSharedCrosshair()
       + dashboard.withVariables([
-          variables.datasource,
-          variables.cluster,
+        variables.datasource,
+        variables.cluster,
       ])
-  }
+      + dashboard.withPanels(
+        g.util.grid.makeGrid([
+          row.new('Overview')
+          + row.withPanels([
+            panels.stat.nodes('Nodes', queries.runningNodes),
+            panels.stat.nodes('Data Nodes', queries.dataNodes),
+            panels.stat.nodes('Pending Tasks', queries.pendingTasks),
+          ]),
+          row.new('Shards')
+          + row.withPanels([
+            panels.stat.nodes('Active', queries.activeShards),
+            panels.stat.nodes('Active Primary', queries.activePrimaryShards),
+            panels.stat.nodes('Initializing', queries.initializingShards),
+            panels.stat.nodes('Relocating', queries.reloactingShards),
+            panels.stat.nodes('Unassigned', queries.unassignedShards),
+            panels.stat.nodes('DelayedUnassigned', queries.delayedUnassignedShards),
+          ]),
+          row.new('Documents')
+          + row.withPanels([
+            panels.timeSeries.base('Indexed Documents', queries.indexedDocuments),
+
+          ]),
+        ], panelWidth=4, panelHeight=3),
+      ),
+  },
 }

elasticsearch_mixin/dashboards/panels.libsonnet

@@ -0,0 +1,29 @@
+local g = import 'g.libsonnet';
+
+{
+  stat: {
+    local stat = g.panel.stat,
+
+    base(title, targets):
+      stat.new(title)
+      + stat.queryOptions.withTargets(targets),
+
+    nodes: self.base,
+  },
+
+  timeSeries: {
+    local timeSeries = g.panel.timeSeries,
+
+    base(title, targets):
+      timeSeries.new(title)
+      + timeSeries.queryOptions.withTargets(targets),
+
+    ratio(title, targets):
+      self.base(title, targets)
+      + timeSeries.standardOptions.withUnit('percentunit'),
+
+    ratioMax1(title, targets):
+      self.ratio(title, targets)
+      + timeSeries.standardOptions.withMax(1),
+  },
+}

elasticsearch_mixin/dashboards/queries.libsonnet

@@ -0,0 +1,115 @@
+local g = import './g.libsonnet';
+local prometheusQuery = g.query.prometheus;
+
+local variables = import './variables.libsonnet';
+
+{
+  /*
+    General overview queries
+  */
+
+  runningNodes:
+    prometheusQuery.new(
+      '$' + variables.datasource.name,
+      |||
+        sum(
+          elasticsearch_cluster_health_number_of_nodes{cluster=~"$cluster"}
+        )
+      |||
+    ),
+  dataNodes:
+    prometheusQuery.new(
+      '$' + variables.datasource.name,
+      |||
+        sum(
+          elasticsearch_cluster_health_number_of_data_nodes{cluster=~"$cluster"}
+        )
+      |||
+    ),
+
+  pendingTasks:
+    prometheusQuery.new(
+      '$' + variables.datasource.name,
+      |||
+        sum(
+          elasticsearch_cluster_health_number_of_pending_tasks{cluster=~"$cluster"}
+        )
+      |||
+    ),
+
+  /*
+    Shard queries
+  */
+
+  activeShards:
+    prometheusQuery.new(
+      '$' + variables.datasource.name,
+      |||
+        sum(
+          elasticsearch_cluster_health_active_shards{cluster=~"$cluster"}
+        )
+      |||
+    ),
+
+  activePrimaryShards:
+    prometheusQuery.new(
+      '$' + variables.datasource.name,
+      |||
+        sum(
+          elasticsearch_cluster_health_active_primary_shards{cluster=~"$cluster"}
+        )
+      |||
+    ),
+
+  initializingShards:
+    prometheusQuery.new(
+      '$' + variables.datasource.name,
+      |||
+        sum(
+          elasticsearch_cluster_health_initializing_shards{cluster=~"$cluster"}
+        )
+      |||
+    ),
+
+  reloactingShards:
+    prometheusQuery.new(
+      '$' + variables.datasource.name,
+      |||
+        sum(
+          elasticsearch_cluster_health_reloacting_shards{cluster=~"$cluster"}
+        )
+      |||
+    ),
+
+  unassignedShards:
+    prometheusQuery.new(
+      '$' + variables.datasource.name,
+      |||
+        sum(
+          elasticsearch_cluster_health_unassigned_shards{cluster=~"$cluster"}
+        )
+      |||
+    ),
+
+  delayedUnassignedShards:
+    prometheusQuery.new(
+      '$' + variables.datasource.name,
+      |||
+        sum(
+          elasticsearch_cluster_health_delayed_unassigned_shards{cluster=~"$cluster"}
+        )
+      |||
+    ),
+
+  /*
+    Documents queries
+  */
+
+  indexedDocuments:
+    prometheusQuery.new(
+      '$' + variables.datasource.name,
+      |||
+        elasticsearch_indices_docs{cluster=~"$cluster"}
+      |||
+    ),
+}