support substitutions in pipelines.yml file

Fixes #11081
This commit is contained in:
Joao Duarte 2019-08-26 16:39:40 +01:00
parent cd91f9b2b3
commit 5f5bbeed14

View file

@ -4,6 +4,7 @@ require "logstash/settings"
module LogStash module Config module Source
class MultiLocal < Local
include LogStash::Util::SubstitutionVariables
include LogStash::Util::Loggable
def initialize(settings)
@ -13,7 +14,7 @@ module LogStash module Config module Source
end
def pipeline_configs
pipelines = retrieve_yaml_pipelines()
pipelines = deep_replace(retrieve_yaml_pipelines())
pipelines_settings = pipelines.map do |pipeline_settings|
clone = @original_settings.clone
clone.merge_pipeline_settings(pipeline_settings)