class Turnstile::Collector::Flusher

Public Instance Methods

execute() click to toggle source
# File lib/turnstile/collector/flusher.rb, line 9
def execute
  flush_current_buffer unless queue.empty?
  queue.size
rescue Exception => e
  puts e.backtrace.reverse.join("\n")
  puts e.inspect.red
  raise e
end
flush_current_buffer() click to toggle source
# File lib/turnstile/collector/flusher.rb, line 18
def flush_current_buffer
  item = queue.pop
  return unless item
  session = parse(item)
  tracker.track(session.uid,
                session.platform,
                session.ip) if session.uid
end
parse(token) click to toggle source
# File lib/turnstile/collector/flusher.rb, line 27
def parse(token)
  # platform, IP, user
  a = token.split(':')

  # session is backwards
  Session.new(a[2], a[0], a[1])
end