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

Version Path
logstash-core-6.0.1-java lib/logstash/api/modules/node.rb
logstash-core-6.0.0-java lib/logstash/api/modules/node.rb
logstash-core-6.0.0.rc2-java lib/logstash/api/modules/node.rb
logstash-core-6.0.0.rc1-java lib/logstash/api/modules/node.rb
logstash-core-6.0.0.beta2-java lib/logstash/api/modules/node.rb
logstash-core-6.0.0.beta1-java lib/logstash/api/modules/node.rb
logstash-core-6.0.0.alpha2-java lib/logstash/api/modules/node.rb