class Zulu::Keeper
Public Instance Methods
start()
click to toggle source
# File lib/zulu/keeper.rb, line 20 def start every(Zulu.options[:interval]) { tick } end
tick(now=Time.now)
click to toggle source
# File lib/zulu/keeper.rb, line 6 def tick(now=Time.now) debug "Looking for topics at: #{now} (#{now.to_i})" count = 0 Topic.happening(now).each do |topic_id| topic = Topic.new(id: topic_id) debug "Found topic: #{topic_id}" distribution = TopicDistribution.new(id: topic_id, now: now) distribution.save topic.reset_next(now) count += 1 end debug "Finished tick: (#{Time.now - now} seconds for #{count} topics)" end