module Sidekiq::Grouping
Constants
- VERSION
Attributes
logger[W]
Public Class Methods
force_flush_for_test!()
click to toggle source
# File lib/sidekiq/grouping.rb, line 27 def force_flush_for_test! Sidekiq::Grouping::Flusher.new.force_flush_for_test! end
logger()
click to toggle source
# File lib/sidekiq/grouping.rb, line 23 def logger @logger ||= Sidekiq.logger end
start!()
click to toggle source
# File lib/sidekiq/grouping.rb, line 31 def start! interval = Sidekiq::Grouping::Config.poll_interval @observer = Sidekiq::Grouping::FlusherObserver.new @task = Concurrent::TimerTask.new( execution_interval: interval ) { Sidekiq::Grouping::Flusher.new.flush } @task.add_observer(@observer) logger.info( "[Sidekiq::Grouping] Started polling batches every " \ "#{interval} seconds" ) @task.execute end