Enable heartbeat telemetry

This commit allows heartbeat telemetry data to be sent through kibana.

The change to beats was introduced in elastic/beats#8621

x-pack/plugins/xpack_main/server/lib/telemetry/monitoring/get_beats_stats.js

@@ -103,6 +103,34 @@ export function processResults(results = [], { clusters, clusterHostSets, cluste
  clusters[clusterUuid].module.count += stateModule.count;
  }
 
+ const heartbeatState = get(hit, '_source.beats_state.state.heartbeat');
+ if (heartbeatState !== undefined) {
+ if (!("heartbeat" in clusters[clusterUuid])) {
+ clusters[clusterUuid].heartbeat = {
+ monitors: 0,
+ endpoints: 0
+ }
+ }
+ var clusterHb = clusters[clusterUuid].heartbeat
+
+ clusterHb.monitors += heartbeatState.monitors 
+ clusterHb.endpoints += heartbeatState.endpoints 
+ for (var proto in heartbeatState) {
+ if (!heartbeatState.hasOwnProperty(proto)) continue;
+ let val = heartbeatState[proto]
+ if (typeof(val) !== "object") continue;
+
+ if (!(proto in clusters[clusterUuid])) {
+ clusterHb[proto] = {
+ monitors: 0,
+ endpoints: 0
+ }
+ }
+ clusterHb[proto].monitors += val.monitors 
+ clusterHb[proto].endpoints += val.endpoints 
+ }
+ }
+
  const stateHost = get(hit, '_source.beats_state.state.host');
  if (stateHost !== undefined) {
  const hostMap = clusterArchitectureMaps[clusterUuid];
@@ -161,6 +189,7 @@ async function fetchBeatsByType(server, callCluster, clusterUuids, start, end, {
  'hits.hits._source.beats_state.state.input',
  'hits.hits._source.beats_state.state.module',
  'hits.hits._source.beats_state.state.host',
+ 'hits.hits._source.beats_state.state.heartbeat',
  ],
  body: {
  query: createQuery({