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