Sha256: f3070951509598d9f4e201f95044d9ffa671339d1cb2c2c5847d534c5f4e7a21
Contents?: true
Size: 1.15 KB
Versions: 7
Compression:
Stored size: 1.15 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 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}) 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
7 entries across 7 versions & 1 rubygems