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

use common

Browse source
This commit is contained in:
Guy Boertje 2017-06-06 17:38:16 +01:00
parent 96df9a7e71
commit 06c97acea7
1 changed files with 6 additions and 31 deletions
Download patch file Download diff file Expand all files Collapse all files

37
logstash-core/lib/logstash/config/source/modules.rb
View file

@ -1,5 +1,6 @@
# encoding: utf-8
require "logstash/config/source/base"
require "logstash/config/modules_common"
require "logstash/config/pipeline_config"
require "logstash/util/loggable"
require "logstash/elasticsearch_client"
@ -10,38 +11,12 @@ module LogStash module Config module Source
class Modules < Base
include LogStash::Util::Loggable
def pipeline_configs
pipelines = []
plugin_modules = LogStash::PLUGIN_REGISTRY.plugins_with_type(:modules)
modules_array = @settings.get("modules.cli").empty? ? @settings.get("modules") : @settings.get("modules.cli")
logger.debug("Configured modules", :modules_array => modules_array.to_s)
module_names = []
module_names = modules_array.collect {|module_hash| module_hash["name"]}
if module_names.length > module_names.uniq.length
duplicate_modules = module_names.group_by(&:to_s).select { |_,v| v.size > 1 }.keys
raise LogStash::ConfigLoadingError, I18n.t("logstash.modules.configuration.modules-must-be-unique", :duplicate_modules => duplicate_modules)
pipelines = LogStash::Config::ModulesCommon.pipeline_configs(@settings)
pipelines.map do |hash|
PipelineConfig.new(self, hash["pipeline_id"].to_sym,
org.logstash.common.SourceWithMetadata.new("module", hash["alt_name"], hash["config_string"]),
hash["settings"])
end
### Here is where we can force the modules_array to use only [0] for 5.5, and leave
### a warning/error message to that effect.
modules_array.each do |module_hash|
begin
import_engine = LogStash::Modules::Importer.new(LogStash::ElasticsearchClient.build(module_hash))
current_module = plugin_modules.find { |allmodules| allmodules.module_name == module_hash["name"] }
alt_name = "module-#{module_hash["name"]}"
pipeline_id = alt_name
current_module.with_settings(module_hash)
current_module.import(import_engine)
config_string = current_module.config_string
config_part = org.logstash.common.SourceWithMetadata.new("module", alt_name, config_string)
pipelines << PipelineConfig.new(self, pipeline_id.to_sym, config_part, @settings)
rescue => e
raise LogStash::ConfigLoadingError, I18n.t("logstash.modules.configuration.parse-failed", :error => e.message)
end
end
pipelines
end
def match?