Sha256: 6e96859ed6e0264433f766921dd8fdb7ab17bba68a5d8a6556b1e54984574f08
Contents?: true
Size: 1.16 KB
Versions: 42
Compression:
Stored size: 1.16 KB
Contents
# frozen_string_literal: true require 'sidekiq/extensions/generic_proxy' module Sidekiq module Extensions ## # Adds 'delay', 'delay_for' and `delay_until` methods to all Classes to offload class method # execution to Sidekiq. Examples: # # User.delay.delete_inactive # Wikipedia.delay.download_changes_for(Date.today) # class DelayedClass include Sidekiq::Worker def perform(yml) (target, method_name, args) = YAML.load(yml) target.__send__(method_name, *args) end end module Klass def sidekiq_delay(options={}) Proxy.new(DelayedClass, self, options) end def sidekiq_delay_for(interval, options={}) Proxy.new(DelayedClass, self, options.merge('at' => Time.now.to_f + interval.to_f)) end def sidekiq_delay_until(timestamp, options={}) Proxy.new(DelayedClass, self, options.merge('at' => timestamp.to_f)) end alias_method :delay, :sidekiq_delay alias_method :delay_for, :sidekiq_delay_for alias_method :delay_until, :sidekiq_delay_until end end end Module.__send__(:include, Sidekiq::Extensions::Klass) unless defined?(::Rails)
Version data entries
42 entries across 42 versions & 3 rubygems