Sha256: 9e627a98870a73f87cd05f5023a08d20af77025b7eb93ff9ea39c2076e02d22d
Contents?: true
Size: 1000 Bytes
Versions: 67
Compression:
Stored size: 1000 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', 'locales', 'errors.yml')
)
).fetch('en').fetch('validations').fetch('job_options')
end
optional(:dispatch_method) do |val|
%i[
produce_async
produce_sync
].include?(val)
end
optional(:dispatch_many_method) do |val|
%i[
produce_many_async
produce_many_sync
].include?(val)
end
end
end
end
Version data entries
67 entries across 67 versions & 1 rubygems