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