module Sidekiq::Merger
Constants
- LOGGER_TAG
- VERSION
Attributes
logger[RW]
Public Class Methods
config()
click to toggle source
# File lib/sidekiq/merger.rb, line 30 def config @config ||= Config.new end
configure() { |config| ... }
click to toggle source
# File lib/sidekiq/merger.rb, line 26 def configure(&block) yield config end
create_task()
click to toggle source
# File lib/sidekiq/merger.rb, line 15 def create_task interval = Sidekiq::Merger::Config.poll_interval observer = Sidekiq::Merger::LoggingObserver.new(logger) flusher = Sidekiq::Merger::Flusher.new(logger) task = Concurrent::TimerTask.new( execution_interval: interval ) { flusher.flush } task.add_observer(observer) task end