class Chewy::Strategy::DelayedSidekiq

Constants

LUA_SCRIPT

Public Class Methods

clear_timechunks!() click to toggle source

cleanup the redis sets used internally. Useful mainly in tests to avoid leak and potential flaky tests.

# File lib/chewy/strategy/delayed_sidekiq.rb, line 10
def self.clear_timechunks!
  ::Sidekiq.redis do |redis|
    keys_to_delete = redis.keys("#{Scheduler::KEY_PREFIX}*")

    # Delete keys one by one
    keys_to_delete.each do |key|
      redis.del(key)
    end
  end
end

Public Instance Methods

leave() click to toggle source
# File lib/chewy/strategy/delayed_sidekiq.rb, line 21
def leave
  @stash.each do |type, ids|
    next if ids.empty?

    DelayedSidekiq::Scheduler.new(type, ids).postpone
  end
end