Sha256: add76a2f28fd4cc58bc5daaf7bec3b8018b65559a4d571cea256db8bd7ca2ea9

Contents?: true

Size: 1.22 KB

Versions: 61

Compression:

Stored size: 1.22 KB

Contents

# frozen_string_literal: true

require_relative "on_conflict/strategy"
require_relative "on_conflict/null_strategy"
require_relative "on_conflict/log"
require_relative "on_conflict/raise"
require_relative "on_conflict/reject"
require_relative "on_conflict/replace"
require_relative "on_conflict/reschedule"

module SidekiqUniqueJobs
  #
  # Provides lock conflict resolutions
  #
  # @author Mikael Henriksson <mikael@mhenrixon.com>
  #
  module OnConflict
    # A convenience method for using the configured strategies
    def self.strategies
      SidekiqUniqueJobs.strategies
    end

    #
    # Find a strategy to use for conflicting locks
    #
    # @param [Symbol] strategy the key for the strategy
    #
    # @return [OnConflict::Strategy] when found
    # @return [OnConflict::NullStrategy] when no other could be found
    #
    def self.find_strategy(strategy)
      return OnConflict::NullStrategy unless strategy

      strategies.fetch(strategy.to_sym) do
        SidekiqUniqueJobs.logger.warn(
          "No matching implementation for strategy: #{strategy}, returning OnConflict::NullStrategy." \
          " Available strategies are (#{strategies.inspect})",
        )

        OnConflict::NullStrategy
      end
    end
  end
end

Version data entries

61 entries across 61 versions & 1 rubygems

Version Path
sidekiq-unique-jobs-8.0.10 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-7.1.33 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-7.1.32 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-8.0.9 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-8.0.8 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-8.0.7 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-8.0.6 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-7.1.31 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-8.0.5 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-8.0.4 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-7.1.30 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-8.0.3 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-8.0.2 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-8.0.1 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-8.0.0 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-7.1.29 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-7.1.28 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-7.1.27 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-7.1.26 lib/sidekiq_unique_jobs/on_conflict.rb
sidekiq-unique-jobs-7.1.25 lib/sidekiq_unique_jobs/on_conflict.rb