class SlowDown::Group
Attributes
config[R]
name[R]
Public Class Methods
all()
click to toggle source
# File lib/slow_down/group.rb, line 7 def self.all @groups ||= {} # rubocop:disable Naming/MemoizedInstanceVariableName end
create(name, options = {})
click to toggle source
# File lib/slow_down/group.rb, line 15 def self.create(name, options = {}) @groups ||= {} @groups[name] = Group.new(name, options) end
find(name)
click to toggle source
# File lib/slow_down/group.rb, line 11 def self.find(name) all[name] end
find_or_create(name, options = {})
click to toggle source
# File lib/slow_down/group.rb, line 20 def self.find_or_create(name, options = {}) if all[name] && !options.empty? all[name].config.logger.error(name) { "Group #{name} has already been configured elsewhere" } raise ConfigError, "Group #{name} has already been configured elsewhere - you may not override configurations" end all[name] || create(name, options) end
new(name, options = {})
click to toggle source
# File lib/slow_down/group.rb, line 41 def initialize(name, options = {}) @name = name @config = Configuration.new({ lock_namespace: name }.merge(options)) end
remove(group_name)
click to toggle source
# File lib/slow_down/group.rb, line 29 def self.remove(group_name) group = Group.find(group_name) || return group.reset @groups.delete(group_name) end
remove_all()
click to toggle source
# File lib/slow_down/group.rb, line 35 def self.remove_all all.each_value(&:remove) end
Public Instance Methods
free?()
click to toggle source
# File lib/slow_down/group.rb, line 65 def free? config.locks.each do |key| if config.redis.set(key, 1, px: config.milliseconds_per_request_per_lock, nx: true) config.logger.info(name) { "Lock #{key} was acquired for #{config.milliseconds_per_request_per_lock}ms" } return true end end false end
remove()
click to toggle source
# File lib/slow_down/group.rb, line 80 def remove Group.remove(@name) end
reset()
click to toggle source
# File lib/slow_down/group.rb, line 76 def reset config.locks.each { |key| config.redis.del(key) } end
run() { || ... }
click to toggle source
# File lib/slow_down/group.rb, line 46 def run expires_at = Time.now + config.timeout iteration = 0 config.logger.info(name) { "Run attempt initiatied, times out at #{expires_at}" } loop do return yield if free? wait(iteration += 1) break if Time.now > expires_at end config.logger.info(name) { "Run attempt timed out" } if config.raise_on_timeout # rubocop:disable Style/GuardClause config.logger.error(name) { "Timeout error raised" } raise Timeout end end
Private Instance Methods
wait(iteration)
click to toggle source
# File lib/slow_down/group.rb, line 86 def wait(iteration) config.logger.debug(name) { "Sleeping for #{config.seconds_per_retry(iteration) * 1000}ms" } sleep(config.seconds_per_retry(iteration)) end