Module: Sidekiq::QueueThrottled

Defined in:
lib/sidekiq/queue_throttled.rb,
lib/sidekiq/queue_throttled/job.rb,
lib/sidekiq/queue_throttled/railtie.rb,
lib/sidekiq/queue_throttled/version.rb,
lib/sidekiq/queue_throttled/middleware.rb,
lib/sidekiq/queue_throttled/configuration.rb,
lib/sidekiq/queue_throttled/job_throttler.rb,
lib/sidekiq/queue_throttled/queue_limiter.rb

Defined Under Namespace

Modules: Job, RedisKeyManager Classes: Configuration, JobThrottler, Middleware, QueueLimiter, Railtie

Constant Summary collapse

VERSION = 
'1.2.0'

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.configuration ⇒ Object 



33
34
35
 
# File 'lib/sidekiq/queue_throttled.rb', line 33

def configuration
  @configuration ||= Configuration.new
end

.logger ⇒ Object 



39
40
41
42
43
44
45
 
# File 'lib/sidekiq/queue_throttled.rb', line 39

def logger
  @logger ||= begin
    logger = Logger.new($stdout)
    logger.level = Logger::INFO
    logger
  end
end

.redis ⇒ Object 



47
48
49
 
# File 'lib/sidekiq/queue_throttled.rb', line 47

def redis
  @redis ||= Sidekiq.redis { |conn| conn }
end

Class Method Details

.configure(config_source = nil) {|configuration| ... } ⇒ Object

Yields:



27
28
29
30
31
 
# File 'lib/sidekiq/queue_throttled.rb', line 27

def configure(config_source = nil)
  yield configuration if block_given?
  configuration.load_configuration!(config_source)
  configuration.validate!
end