Module: Sidekiq::Grouping

Defined in:
lib/sidekiq/grouping/web.rb,
lib/sidekiq/grouping/batch.rb,
lib/sidekiq/grouping/redis.rb,
lib/sidekiq/grouping/version.rb,
lib/sidekiq/grouping/middleware.rb,
lib/sidekiq/grouping.rb

Defined Under Namespace

Modules: Config, Web Classes: Batch, Flusher, FlusherObserver, Middleware, Redis

Constant Summary collapse

VERSION = 
"1.1.0"

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.logger ⇒ Object 



19
20
21
 
# File 'lib/sidekiq/grouping.rb', line 19

def logger
  @logger ||= Sidekiq.logger
end

Class Method Details

.force_flush_for_test! ⇒ Object 



23
24
25
 
# File 'lib/sidekiq/grouping.rb', line 23

def force_flush_for_test!
  Sidekiq::Grouping::Flusher.new.force_flush_for_test!
end

.start! ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
 
# File 'lib/sidekiq/grouping.rb', line 27

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