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

Restore UUID lookup to node (#10884) (#10911)

Browse source 
* Restore UUID lookup to node

* Fix incorrect merge

* Move private method to bottom

* Change method name per review suggestion

* Update method description
This commit is contained in:
Mike Place 2019-06-26 23:05:33 +02:00 • committed by GitHub
parent 9a5faf24bf
commit c918082617
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 22 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

23
logstash-core/lib/logstash/api/commands/node.rb
View file

@ -38,7 +38,10 @@ module LogStash
:dead_letter_queue_path,
).reject{|_, v|v.nil?}
if options.fetch(:graph, false)
metrics.merge!(extract_metrics([:stats, :pipelines, pipeline_id.to_sym, :config], :graph))
extended_stats = extract_metrics([:stats, :pipelines, pipeline_id.to_sym, :config], :graph)
decorated_vertices = extended_stats[:graph]["graph"]["vertices"].map { |vertex| decorate_with_cluster_uuids(vertex) }
extended_stats[:graph]["graph"]["vertices"] = decorated_vertices
metrics.merge!(extended_stats)
end
metrics
rescue
@ -77,6 +80,24 @@ module LogStash
def hot_threads(options={})
HotThreadsReport.new(self, options)
end
private
##
# Returns a vertex, decorated with the cluster UUID metadata retrieved from ES
# Does not mutate the passed `vertex` object.
# @api private
# @param vertex [Hash{String=>Object}]
# @return [Hash{String=>Object}]
def decorate_with_cluster_uuids(vertex)
plugin_id = vertex["id"]&.to_s
return vertex unless plugin_id && LogStash::PluginMetadata.exists?(plugin_id)
plugin_metadata = LogStash::PluginMetadata.for_plugin(plugin_id)
cluster_uuid = plugin_metadata&.get(:cluster_uuid)
vertex = vertex.merge("cluster_uuid" => cluster_uuid) unless cluster_uuid.nil?
vertex
end
end
end
end