class Lita::Timing::RateLimit
Public Class Methods
new(name, redis)
click to toggle source
# File lib/lita/timing/rate_limit.rb, line 4 def initialize(name, redis) @name, @redis = name, redis @mutex = Timing::Mutex.new("#{name}-lock", redis) end
Public Instance Methods
last_time()
click to toggle source
# File lib/lita/timing/rate_limit.rb, line 18 def last_time value = @redis.get(@name) value ? Time.at(value.to_i).utc : nil end
once_every(seconds) { || ... }
click to toggle source
# File lib/lita/timing/rate_limit.rb, line 9 def once_every(seconds, &block) @mutex.syncronise do if last_time.nil? || last_time + seconds < Time.now yield @redis.set(@name, Time.now.to_i, ex: seconds * 2) end end end