Sha256: 7d40635bf2ef622d8480bcc2c0bae80e43464eef1235444e8fd8340e49bff92a

Contents?: true

Size: 792 Bytes

Versions: 29

Compression:

Stored size: 792 Bytes

Contents

# frozen_string_literal: true

module Karafka
  module ActiveJob
    # Contract for validating the options that can be altered with `#karafka_options` per job class
    # @note We keep this in the `Karafka::ActiveJob` namespace instead of `Karafka::Contracts` as
    #   we want to keep ActiveJob related Karafka components outside of the core Karafka code and
    #   all in the same place
    class JobOptionsContract < Contracts::Base
      configure do |config|
        config.error_messages = YAML.safe_load(
          File.read(
            File.join(Karafka.gem_root, 'config', 'errors.yml')
          )
        ).fetch('en').fetch('validations').fetch('job_options')
      end

      optional(:dispatch_method) { |val| %i[produce_async produce_sync].include?(val) }
    end
  end
end

Version data entries

29 entries across 29 versions & 1 rubygems

Version Path
karafka-2.0.23 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.22 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.21 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.20 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.19 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.18 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.17 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.16 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.15 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.14 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.13 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.12 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.11 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.10 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.9 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.8 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.7 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.6 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.5 lib/karafka/active_job/job_options_contract.rb
karafka-2.0.4 lib/karafka/active_job/job_options_contract.rb