Sha256: 547f6c6fd35726a8c9883b630ceffaf445e92f77d5a5ad93463a95be8080bc4a
Contents?: true
Size: 804 Bytes
Versions: 61
Compression:
Stored size: 804 Bytes
Contents
# frozen_string_literal: true
module SidekiqUniqueJobs
class Lock
#
# Validates the sidekiq options for the Sidekiq client process
#
# @author Mikael Henriksson <mikael@mhenrixon.com>
#
class ClientValidator
#
# @return [Array<Symbol>] a collection of invalid conflict resolutions
INVALID_ON_CONFLICTS = [:raise, :reject, :reschedule].freeze
#
# Validates the sidekiq options for the Sidekiq client process
#
#
def self.validate(lock_config)
on_conflict = lock_config.on_client_conflict
return lock_config unless INVALID_ON_CONFLICTS.include?(on_conflict)
lock_config.errors[:on_client_conflict] = "#{on_conflict} is incompatible with the client process"
lock_config
end
end
end
end
Version data entries
61 entries across 61 versions & 1 rubygems