Sha256: 411d944b2a7ae29fb8392043d2c137f32e605a352f45eed84e27fe47e996a438
Contents?: true
Size: 1.32 KB
Versions: 61
Compression:
Stored size: 1.32 KB
Contents
# encoding: utf-8
require "logstash/api/modules/base"
require "logstash/api/errors"
module LogStash
module Api
module Modules
class Node < ::LogStash::Api::Modules::Base
def node
factory.build(:node)
end
get "/hot_threads" do
begin
ignore_idle_threads = params["ignore_idle_threads"] || true
options = {:ignore_idle_threads => as_boolean(ignore_idle_threads)}
options[:threads] = params["threads"].to_i if params.has_key?("threads")
as = human? ? :string : :json
respond_with(node.hot_threads(options), {:as => as})
rescue ArgumentError => e
response = respond_with({"error" => e.message})
status(400)
response
end
end
get "/pipelines/:id" do
pipeline_id = params["id"]
payload = node.pipeline(pipeline_id)
halt(404) if payload.empty?
respond_with(:pipelines => { pipeline_id => payload } )
end
get "/?:filter?" do
selected_fields = extract_fields(params["filter"].to_s.strip)
values = node.all(selected_fields)
if values.size == 0
raise NotFoundError
else
respond_with(values)
end
end
end
end
end
end
Version data entries
61 entries across 61 versions & 1 rubygems