d0595fdc4b
* Separate bulk upload behavior from CollectorSet
- takes out a lot of behavior from CollectorSet and moves it to a class called BulkUploader
- simplifies kibana monitoring init by taking out the indirection that startCollectorSet / createCollectorSet had
- removes start() method from CollectorSet and calls the collector objects' init() functions from CollectorSet.register()
- removes cleanup method from collectorSet since that was doing work for bulk uploading
* remove cleanup and fetchAfterInit methods
* test for bulk_uploader class
* improve test for collector_set
* fix reporting
* expose collectorSet if there actually is a collectorSet
* comment for enclosed function
* make collectorSet creation/expose unconditional, bulkUploader more conditional
* fix collector_set tests
* lifecycle events
* stab at collectorSet error logging from the API call
* clean up comments
* clean up comments
* fix BulkUploader mocha test
* check kibanaCollectionEnabled config before registering bulk upload and the plugin status listeners
* no singleton timer object
* just log a warning if bulk uploader start called twice
* normal quotes
* check if bulk is enabled inside of the _fetchAndUpload method
* log for stopping bulk stats
* call bulkUploader.start with the collectorSet object
* call bulkUploader.start with the collectorSet object
* roll back change for module scoped variable
* oops I broke init
* init and logging: if / elseif / elseif
* remove unnecessary check/log
* help log
* remove redundant, use data.filter.map
* use xpackInfo.onLicenseInfoChange not xpackMainPlugin.status.on('green')
* help logging
* fix unit test
* remove handler that stops upload when connection is lost
98 lines
4.1 KiB
JavaScript
98 lines
4.1 KiB
JavaScript
/*
|
|
* Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
|
|
* or more contributor license agreements. Licensed under the Elastic License;
|
|
* you may not use this file except in compliance with the Elastic License.
|
|
*/
|
|
|
|
import { LOGGING_TAG, KIBANA_MONITORING_LOGGING_TAG, } from './common/constants';
|
|
import { requireUIRoutes } from './server/routes';
|
|
import { instantiateClient } from './server/es_client/instantiate_client';
|
|
import { initMonitoringXpackInfo } from './server/init_monitoring_xpack_info';
|
|
import { CollectorSet } from './server/kibana_monitoring/classes';
|
|
import { initBulkUploader } from './server/kibana_monitoring';
|
|
import {
|
|
getKibanaUsageCollector,
|
|
getOpsStatsCollector,
|
|
getSettingsCollector,
|
|
} from './server/kibana_monitoring/collectors';
|
|
|
|
/**
|
|
* Initialize the Kibana Monitoring plugin by starting up asynchronous server tasks
|
|
* - [1] instantiation of an elasticsearch-js client exposed as a server plugin object
|
|
* - [2] start monitoring cluster x-pack license and features check
|
|
* - [3] webserver route handling
|
|
* - [4] start the internal monitoring collector/bulk uploader
|
|
* - [5] expose the monitoring collector object for other plugins to register with
|
|
* @param monitoringPlugin {Object} Monitoring UI plugin
|
|
* @param server {Object} HapiJS server instance
|
|
*/
|
|
export const init = (monitoringPlugin, server) => {
|
|
const config = server.config();
|
|
|
|
const collectorSet = new CollectorSet(server);
|
|
server.expose('collectorSet', collectorSet); // expose the collectorSet service
|
|
/*
|
|
* Register collector objects for stats to show up in the APIs
|
|
*/
|
|
collectorSet.register(getOpsStatsCollector(server));
|
|
collectorSet.register(getKibanaUsageCollector(server));
|
|
collectorSet.register(getSettingsCollector(server));
|
|
|
|
/*
|
|
* Instantiate and start the internal background task that calls collector
|
|
* fetch methods and uploads to the ES monitoring bulk endpoint
|
|
*/
|
|
const xpackMainPlugin = server.plugins.xpack_main;
|
|
xpackMainPlugin.status.once('green', async () => { // first time xpack_main turns green
|
|
/*
|
|
* End-user-facing services
|
|
*/
|
|
const uiEnabled = config.get('xpack.monitoring.ui.enabled');
|
|
|
|
if (uiEnabled) {
|
|
await instantiateClient(server); // Instantiate the dedicated ES client
|
|
await initMonitoringXpackInfo(server); // Route handlers depend on this for xpackInfo
|
|
await requireUIRoutes(server);
|
|
}
|
|
});
|
|
|
|
const bulkUploader = initBulkUploader(monitoringPlugin.kbnServer, server);
|
|
const kibanaCollectionEnabled = config.get('xpack.monitoring.kibana.collection.enabled');
|
|
const { info: xpackMainInfo } = xpackMainPlugin;
|
|
|
|
if (kibanaCollectionEnabled) {
|
|
/*
|
|
* Bulk uploading of Kibana stats
|
|
*/
|
|
xpackMainInfo.onLicenseInfoChange(() => {
|
|
// use updated xpack license info to start/stop bulk upload
|
|
const mainMonitoring = xpackMainInfo.feature('monitoring');
|
|
const monitoringBulkEnabled = mainMonitoring && mainMonitoring.isAvailable() && mainMonitoring.isEnabled();
|
|
if (monitoringBulkEnabled) {
|
|
bulkUploader.start(collectorSet);
|
|
} else {
|
|
bulkUploader.handleNotEnabled();
|
|
}
|
|
});
|
|
} else if (!kibanaCollectionEnabled) {
|
|
server.log(
|
|
['info', LOGGING_TAG, KIBANA_MONITORING_LOGGING_TAG],
|
|
'Internal collection for Kibana monitoring will is disabled per configuration.'
|
|
);
|
|
}
|
|
|
|
server.injectUiAppVars('monitoring', (server) => {
|
|
const config = server.config();
|
|
return {
|
|
maxBucketSize: config.get('xpack.monitoring.max_bucket_size'),
|
|
minIntervalSeconds: config.get('xpack.monitoring.min_interval_seconds'),
|
|
kbnIndex: config.get('kibana.index'),
|
|
esApiVersion: config.get('elasticsearch.apiVersion'),
|
|
esShardTimeout: config.get('elasticsearch.shardTimeout'),
|
|
showLicenseExpiration: config.get('xpack.monitoring.show_license_expiration'),
|
|
showCgroupMetricsElasticsearch: config.get('xpack.monitoring.ui.container.elasticsearch.enabled'),
|
|
showCgroupMetricsLogstash: config.get('xpack.monitoring.ui.container.logstash.enabled') // Note, not currently used, but see https://github.com/elastic/x-pack-kibana/issues/1559 part 2
|
|
};
|
|
});
|
|
};
|