mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 22:57:16 -04:00
- give a more helpful message on plugin load failure (LOGSTASH-146)
This commit is contained in:
parent
af52de9b64
commit
ec5a2560da
1 changed files with 11 additions and 9 deletions
|
@ -2,12 +2,16 @@ require "logstash/namespace"
|
|||
require "logstash/config/grammar"
|
||||
require "logstash/config/registry"
|
||||
require "logstash/agent"
|
||||
require "logger"
|
||||
|
||||
class LogStash::Config::File
|
||||
attr_accessor :logger
|
||||
|
||||
public
|
||||
def initialize(path=nil, string=nil)
|
||||
@path = path
|
||||
@string = string
|
||||
@logger = Logger.new(STDERR)
|
||||
|
||||
if (path.nil? and string.nil?) or (!path.nil? and !string.nil?)
|
||||
raise "Must give path or string, not both or neither"
|
||||
|
@ -50,15 +54,15 @@ class LogStash::Config::File
|
|||
def tryload(parent, child)
|
||||
child = child.downcase if child.is_a? String
|
||||
begin
|
||||
loaded = (require "logstash/#{parent}s/#{child}")
|
||||
#if loaded
|
||||
#puts "Loading logstash/#{parent}s/#{child}"
|
||||
#end
|
||||
rescue => e
|
||||
loaded = require("logstash/#{parent}s/#{child}")
|
||||
rescue LoadError => e
|
||||
if child == :base
|
||||
$stderr.puts "Failure loading base class '#{parent}': #{e.inspect}"
|
||||
@logger.fatal("Failure loading plugin type '#{parent}' - is that " \
|
||||
"really a valid plugin type? (check for typos!)")
|
||||
else
|
||||
$stderr.puts "Failure loading plugin #{parent}s/#{child}: #{e.inspect}"
|
||||
@logger.fatal("Failure loading plugin from config: " \
|
||||
"'#{parent} { #{child} { ... } }' - is that " \
|
||||
"really a valid #{parent} plugin? (check for typos!)")
|
||||
end
|
||||
raise e
|
||||
end
|
||||
|
@ -66,8 +70,6 @@ class LogStash::Config::File
|
|||
|
||||
public
|
||||
def each(&block)
|
||||
#ap @config
|
||||
|
||||
# First level is the components
|
||||
# Like:
|
||||
# input {
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue