Sha256: 9766a69acafceb2173f4bd700759cfad772d415483d038ee70ac5d15acdfef1c
Contents?: true
Size: 728 Bytes
Versions: 17
Compression:
Stored size: 728 Bytes
Contents
module CanvasSync::JobUniqueness
module OnConflict
class Base
attr_reader :lock_context
attr_reader :redis_pool
class_attribute :_valid_for, instance_writer: false
def self.valid_for(*origins)
if origins.present?
orgins = Array(origins).map(&:to_sym)
self._valid_for = origins
else
self._valid_for || [:enqueue, :perform]
end
end
def initialize(lock_context, redis_pool = nil)
@lock_context = lock_context
@redis_pool = redis_pool
end
def call
raise NotImplementedError, "needs to be implemented in child class"
end
def replace?
is_a?(Replace)
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems