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