class Kishu::Pipeline
Public Class Methods
new()
click to toggle source
# File lib/kishu/pipeline.rb, line 11 def initialize @conn = Faraday.new(:url => LOGSTASH_HOST) # logger = Logger.new(STDOUT) # logger.info end
Public Instance Methods
is_ready?()
click to toggle source
# File lib/kishu/pipeline.rb, line 17 def is_ready? main = @conn.get do |req| req.url '/_node/stats/pipelines/main' end response = JSON.parse(main.body) return nil unless response.dig("pipelines","main","events","out") == 0 end
status?()
click to toggle source
# File lib/kishu/pipeline.rb, line 25 def status? main = @conn.get do |req| req.url '/_node/stats/pipelines/main' req.options.timeout = 200 end response = JSON.parse(main.body) puts "Pipeline Status" puts response.dig("pipelines","main","events") puts response.dig("pipelines","main","events","in") puts response.dig("pipelines","main","events","out") end