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