mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 22:57:16 -04:00
parent
6bc3ba4804
commit
d4a915be2b
1 changed files with 10 additions and 1 deletions
|
@ -27,7 +27,16 @@ module LogStash
|
||||||
def pipeline(pipeline_id)
|
def pipeline(pipeline_id)
|
||||||
extract_metrics(
|
extract_metrics(
|
||||||
[:stats, :pipelines, pipeline_id.to_sym, :config],
|
[:stats, :pipelines, pipeline_id.to_sym, :config],
|
||||||
:graph, :ephemeral_id, :hash, :workers, :batch_size, :batch_delay, :config_reload_automatic, :config_reload_interval, :dead_letter_queue_enabled, :dead_letter_queue_path
|
:graph,
|
||||||
|
:ephemeral_id,
|
||||||
|
:hash,
|
||||||
|
:workers,
|
||||||
|
:batch_size,
|
||||||
|
:batch_delay,
|
||||||
|
:config_reload_automatic,
|
||||||
|
:config_reload_interval,
|
||||||
|
:dead_letter_queue_enabled,
|
||||||
|
:dead_letter_queue_path
|
||||||
).reject{|_, v|v.nil?}
|
).reject{|_, v|v.nil?}
|
||||||
rescue
|
rescue
|
||||||
{}
|
{}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue