Module: Sidekiq::Ultimate

Defined in:
lib/sidekiq/ultimate.rb,
lib/sidekiq/ultimate/fetch.rb,
lib/sidekiq/ultimate/version.rb,
lib/sidekiq/ultimate/queue_name.rb,
lib/sidekiq/ultimate/resurrector.rb,
lib/sidekiq/ultimate/empty_queues.rb,
lib/sidekiq/ultimate/unit_of_work.rb,
lib/sidekiq/ultimate/configuration.rb,
lib/sidekiq/ultimate/expirable_set.rb,
lib/sidekiq/ultimate/resurrector/lock.rb,
lib/sidekiq/ultimate/resurrector/count.rb,
lib/sidekiq/ultimate/interval_with_jitter.rb,
lib/sidekiq/ultimate/resurrector/common_constants.rb,
lib/sidekiq/ultimate/empty_queues/refresh_timer_task.rb,
lib/sidekiq/ultimate/resurrector/resurrection_script.rb

Overview

Sidekiq ultimate experience.

Defined Under Namespace

Modules: Resurrector Classes: Configuration, EmptyQueues, ExpirableSet, Fetch, IntervalWithJitter, QueueName, UnitOfWork

Constant Summary collapse

VERSION = 
"2.0.0"

Class Method Summary collapse

Class Method Details

.setup!(&configuration_block) ⇒ void

This method returns an undefined value.

Sets up reliable throttled fetch and friends.



14
15
16
17
18
19
20
21
 
# File 'lib/sidekiq/ultimate.rb', line 14

def setup!(&configuration_block)
  configuration_block&.call(Sidekiq::Ultimate::Configuration.instance)

  Sidekiq::Throttled::Communicator.instance.setup!
  Sidekiq::Throttled::QueuesPauser.instance.setup!

  sidekiq_configure_server
end