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