From f4bb11ae9ebb530778bfe1bb98e619a1a87968ce Mon Sep 17 00:00:00 2001 From: Chris Roberson Date: Fri, 24 May 2019 09:08:38 -0400 Subject: [PATCH] Once the buffer has any events, the collector is always ready (#36995) --- .../collectors/get_ops_stats_collector.js | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/x-pack/plugins/monitoring/server/kibana_monitoring/collectors/get_ops_stats_collector.js b/x-pack/plugins/monitoring/server/kibana_monitoring/collectors/get_ops_stats_collector.js index 509689df84d8c1..b5116de7f3d499 100644 --- a/x-pack/plugins/monitoring/server/kibana_monitoring/collectors/get_ops_stats_collector.js +++ b/x-pack/plugins/monitoring/server/kibana_monitoring/collectors/get_ops_stats_collector.js @@ -13,6 +13,7 @@ import { opsBuffer } from './ops_buffer'; import Oppsy from 'oppsy'; import { cloneDeep } from 'lodash'; +let bufferHadEvents = false; class OpsMonitor { constructor(server, buffer, interval) { @@ -80,7 +81,12 @@ export function getOpsStatsCollector(server, kbnServer) { return collectorSet.makeStatsCollector({ type: KIBANA_STATS_TYPE_MONITORING, init: opsMonitor.start, - isReady: () => buffer.hasEvents(), + isReady: () => { + if (!bufferHadEvents) { + bufferHadEvents = buffer.hasEvents(); + } + return bufferHadEvents; + }, fetch: async () => { return await buffer.flush(); }