github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 22:57:16 -04:00
Code Issues Projects Releases Packages Wiki Activity

Incorporate review comments

Browse source 
Fixes #11777
This commit is contained in:
Rob Bavey 2020-04-13 09:07:23 -04:00 • committed by Robert Bavey
parent d33195750e
commit c00c3da95a
1 changed files with 5 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

16
x-pack/lib/monitoring/inputs/metrics.rb
View file

@ -211,18 +211,12 @@ module LogStash module Inputs
end
def extract_cluster_uuids(stats)
cluster_uuids = []
agent.running_pipelines.each do |pipeline_id, _|
unless pipeline_id.to_sym == :".monitoring-logstash"
path = [:stats, :pipelines, pipeline_id.to_sym, :config]
found_cluster_uuids = stats.extract_metrics(path, :cluster_uuids)
if found_cluster_uuids && !found_cluster_uuids[:cluster_uuids].empty?
cluster_uuids |= found_cluster_uuids[:cluster_uuids]
end
end
end
cluster_uuids = agent.running_pipelines.flat_map do |_, pipeline|
next if pipeline.system?
pipeline.resolve_cluster_uuids
end.compact.uniq
unless cluster_uuids.empty?
if cluster_uuids.any?
@logger.info("Found cluster_uuids from elasticsearch output plugins", :cluster_uuids => cluster_uuids)
if LogStash::SETTINGS.set?("monitoring.cluster_uuid")
@logger.warn("Found monitoring.cluster_uuid setting configured in logstash.yml while using the ones discovered from elasticsearch output plugins, ignoring setting monitoring.cluster_uuid")