class Norikra::Client::Event

Public Instance Methods

fetch(query_name) click to toggle source
# File lib/norikra/client/cli.rb, line 215
def fetch(query_name)
  formatter = formatter(options[:format])
  time_formatter = lambda{|t| Time.at(t).strftime(options[:time_format])}

  wrap do
    client(parent_options).event(query_name).each do |time,event|
      event = {options[:time_key] => Time.at(time).strftime(options[:time_format])}.merge(event)
      puts formatter.format(event)
    end
  end
end
see(query_name) click to toggle source
# File lib/norikra/client/cli.rb, line 231
def see(query_name)
  formatter = formatter(options[:format])
  time_formatter = lambda{|t| Time.at(t).strftime(options[:time_format])}

  wrap do
    client(parent_options).see(query_name).each do |time,event|
      event = {options[:time_key] => Time.at(time).strftime(options[:time_format])}.merge(event)
      puts formatter.format(event)
    end
  end
end
send(target) click to toggle source
# File lib/norikra/client/cli.rb, line 194
def send(target)
  client = client(parent_options)
  parser = parser(options[:format])
  buffer = []
  $stdin.each_line do |line|
    buffer.push(parser.parse(line))
    if buffer.size >= options[:batch_size]
      client.send(target, buffer)
      buffer = []
    end
  end

  wrap do
    client.send(target, buffer) if buffer.size > 0
  end
end
sweep(query_group=nil) click to toggle source
# File lib/norikra/client/cli.rb, line 248
def sweep(query_group=nil)
  wrap do
    formatter = formatter(options[:format])
    time_formatter = lambda{|t| Time.at(t).strftime(options[:time_format])}

    data = client(parent_options).sweep(query_group)

    data.keys.sort.each do |queryname|
      events = data[queryname]
      events.each do |time,event|
        event = {
          options[:time_key] => Time.at(time).strftime(options[:time_format]),
          options[:query_name_key] => queryname,
        }.merge(event)
        puts formatter.format(event)
      end
    end
  end
end