github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-24 01:38:56 -04:00
Code Issues Projects Releases Packages Wiki Activity

[Telemetry] Add beats architecture stats to telemetry (#21227) (#22412)

Browse source 
* Add beats architecture stats to telemetry

* Update tests

* PR feedback

* Use values instead of keys
This commit is contained in:
Chris Roberson 2018-08-29 14:06:07 -04:00 • committed by GitHub
parent 3b2823d433
commit b980f6e13a
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 67 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

20
x-pack/plugins/xpack_main/server/lib/telemetry/monitoring/__tests__/fixtures/beats_stats_results.json
View file

@ -34,6 +34,26 @@
}
}
},
{
"_source": {
"type": "beats_state",
"cluster_uuid": "W7hppdX7R229Oy3KQbZrTw",
"beats_state": {
"state": {
"host": {
"name": "Elastic-MBP.local",
"architecture": "x86_64",
"os": {
"platform": "darwin",
"version": "10.13.6",
"family": "darwin",
"build": "17G65"
}
}
}
}
}
},
{
"_source": {
"type": "beats_stats",

19
x-pack/plugins/xpack_main/server/lib/telemetry/monitoring/__tests__/get_beats_stats.js
View file

@ -14,6 +14,7 @@ const getBaseOptions = () => ({
clusterHostSets: {},
clusterInputSets: {},
clusterModuleSets: {},
clusterArchitectureMaps: {}
});
describe('Get Beats Stats', () => {
@ -111,6 +112,10 @@ describe('Get Beats Stats', () => {
count: 0,
names: [],
},
architecture: {
count: 0,
architectures: []
}
},
});
});
@ -140,6 +145,16 @@ describe('Get Beats Stats', () => {
count: 1,
names: [ 'firehose' ],
},
architecture: {
count: 1,
architectures: [
{
architecture: 'x86_64',
count: 1,
name: 'darwin'
}
]
}
},
FlV4ckTxQ0a78hmBkzzc9A: {
count: 405,
@ -165,6 +180,10 @@ describe('Get Beats Stats', () => {
count: 0,
names: [],
},
architecture: {
count: 0,
architectures: []
}
},
});
});

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

@ -26,6 +26,10 @@ const getBaseStats = () => ({
count: 0,
names: []
},
architecture: {
count: 0,
architectures: []
}
});
@ -37,7 +41,7 @@ const getBaseStats = () => ({
* @param {Object} clusterHostSets - the object keyed by cluster UUIDs to count the unique hosts
* @param {Object} clusterModuleSets - the object keyed by cluster UUIDs to count the unique modules
*/
export function processResults(results = [], { clusters, clusterHostSets, clusterInputSets, clusterModuleSets }) {
export function processResults(results = [], { clusters, clusterHostSets, clusterInputSets, clusterModuleSets, clusterArchitectureMaps }) {
const currHits = get(results, 'hits.hits', []);
currHits.forEach(hit => {
const clusterUuid = get(hit, '_source.cluster_uuid');
@ -46,6 +50,7 @@ export function processResults(results = [], { clusters, clusterHostSets, cluste
clusterHostSets[clusterUuid] = new Set();
clusterInputSets[clusterUuid] = new Set();
clusterModuleSets[clusterUuid] = new Set();
clusterArchitectureMaps[clusterUuid] = new Map();
}
const processBeatsStatsResults = () => {
@ -97,6 +102,25 @@ export function processResults(results = [], { clusters, clusterHostSets, cluste
clusters[clusterUuid].module.names = Array.from(moduleSet);
clusters[clusterUuid].module.count += stateModule.count;
}
const stateHost = get(hit, '_source.beats_state.state.host');
if (stateHost !== undefined) {
const hostMap = clusterArchitectureMaps[clusterUuid];
const hostKey = `${stateHost.architecture}/${stateHost.os.platform}`;
let os = hostMap.get(hostKey);
if (!os) { // undefined if new
os = { name: stateHost.os.platform, architecture: stateHost.architecture, count: 0 };
hostMap.set(hostKey, os);
}
// total per os/arch
os.count += 1;
// overall total (which should be the same number as the sum of all os.count values)
clusters[clusterUuid].architecture.count += 1;
clusters[clusterUuid].architecture.architectures = Array.from(hostMap.values());
}
};
if (get(hit, '_source.type') === 'beats_stats') {
@ -136,6 +160,7 @@ async function fetchBeatsByType(server, callCluster, clusterUuids, start, end, {
'hits.hits._source.beats_stats.metrics.libbeat.output.type',
'hits.hits._source.beats_state.state.input',
'hits.hits._source.beats_state.state.module',
'hits.hits._source.beats_state.state.host',
],
body: {
query: createQuery({
@ -194,7 +219,8 @@ export async function getBeatsStats(server, callCluster, clusterUuids, start, en
clusters: {}, // the result object to be built up
clusterHostSets: {}, // passed to processResults for tracking state in the results generation
clusterInputSets: {}, // passed to processResults for tracking state in the results generation
clusterModuleSets: {} // passed to processResults for tracking state in the results generation
clusterModuleSets: {}, // passed to processResults for tracking state in the results generation
clusterArchitectureMaps: {} // passed to processResults for tracking state in the results generation
};
await Promise.all([