Sha256: 69028c31e497883bbbdfbd387e86f8b899b3bbe3a058b93b83863631c351d431
Contents?: true
Size: 1.94 KB
Versions: 8
Compression:
Stored size: 1.94 KB
Contents
# encoding: utf-8
#
java_import org.apache.logging.log4j.core.LoggerContext
module LogStash
module Api
module Modules
class Logging < ::LogStash::Api::Modules::Base
# retrieve logging specific parameters from the provided settings
#
# return any unused configurations
def handle_logging(settings)
Hash[settings.map do |key, level|
if key.start_with?("logger.")
_, path = key.split("logger.")
LogStash::Logging::Logger::configure_logging(level, path)
nil
else
[key, level]
end
end]
end
put "/" do
begin
request.body.rewind
req_body = LogStash::Json.load(request.body.read)
remaining = handle_logging(req_body)
unless remaining.empty?
raise ArgumentError, I18n.t("logstash.web_api.logging.unrecognized_option", :option => remaining.keys.first)
end
respond_with({"acknowledged" => true})
rescue ArgumentError => e
status 400
respond_with({"error" => e.message})
end
end
put "/reset" do
context = LogStash::Logging::Logger::get_logging_context
if context.nil?
status 500
respond_with({"error" => "Logstash loggers were not initialized properly"})
else
context.reconfigure
respond_with({"acknowledged" => true})
end
end
get "/" do
context = LogStash::Logging::Logger::get_logging_context
if context.nil?
status 500
respond_with({"error" => "Logstash loggers were not initialized properly"})
else
loggers = context.getLoggers.map { |lgr| [lgr.getName, lgr.getLevel.name] }.sort
respond_with({"loggers" => Hash[loggers]})
end
end
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems