Sha256: 0967833f846498fac1e3c7606075fe0c1b07faca5c28b162e976d834e31dd643
Contents?: true
Size: 1.92 KB
Versions: 8
Compression:
Stored size: 1.92 KB
Contents
# frozen_string_literal: true
# This Karafka component is a Pro component under a commercial license.
# This Karafka component is NOT licensed under LGPL.
#
# All of the commercial components are present in the lib/karafka/pro directory of this
# repository and their usage requires commercial license agreement.
#
# Karafka has also commercial-friendly license, commercial support and commercial components.
#
# By sending a pull request to the pro components, you are agreeing to transfer the copyright of
# your code to Maciej Mensfeld.
module Karafka
module Pro
module RecurringTasks
# Setup and config related recurring tasks components
module Setup
# Config for recurring tasks
class Config
extend ::Karafka::Core::Configurable
setting(:consumer_class, default: Consumer)
setting(:deserializer, default: Deserializer.new)
setting(:group_id, default: 'karafka_recurring_tasks')
# By default we will run the scheduling every 15 seconds since we provide a minute-based
# precision
setting(:interval, default: 15_000)
# Should we log the executions. If true (default) with each cron execution, there will
# be a special message published. Useful for debugging.
setting(:logging, default: true)
# Producer to be used by the recurring tasks.
# By default it is a `Karafka.producer`, however it may be overwritten if we want to use
# a separate instance in case of heavy usage of the transactional producer, etc.
setting(
:producer,
constructor: -> { ::Karafka.producer },
lazy: true
)
setting(:topics) do
setting(:schedules, default: 'karafka_recurring_tasks_schedules')
setting(:logs, default: 'karafka_recurring_tasks_logs')
end
configure
end
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems