Class: Sidekiq::Capsule
- Inherits:
-
Object
- Object
- Sidekiq::Capsule
- Extended by:
- Forwardable
- Includes:
- Component
- Defined in:
- lib/sidekiq/capsule.rb
Overview
A Sidekiq::Capsule is the set of resources necessary to process one or more queues with a given concurrency. One “default” Capsule is started but the user may declare additional Capsules in their initializer.
This capsule will pull jobs from the “single” queue and process the jobs with one thread, meaning the jobs will be processed serially.
Sidekiq.configure_server do |config|
config.capsule("single-threaded") do |cap|
cap.concurrency = 1
cap.queues = %w(single)
end
end
Instance Attribute Summary collapse
-
#concurrency ⇒ Object
Returns the value of attribute concurrency.
-
#mode ⇒ Object
readonly
Returns the value of attribute mode.
-
#name ⇒ Object
readonly
Returns the value of attribute name.
-
#queues ⇒ Object
Returns the value of attribute queues.
-
#weights ⇒ Object
readonly
Returns the value of attribute weights.
Attributes included from Component
Instance Method Summary collapse
-
#client_middleware {|@client_chain| ... } ⇒ Object
Allow the middleware to be different per-capsule.
- #fetcher ⇒ Object
-
#initialize(name, config) ⇒ Capsule
constructor
A new instance of Capsule.
- #local_redis_pool ⇒ Object
- #logger ⇒ Object
- #lookup(name) ⇒ Object
- #redis ⇒ Object
- #redis_pool ⇒ Object
- #server_middleware {|@server_chain| ... } ⇒ Object
- #stop ⇒ Object
Methods included from Component
#fire_event, #handle_exception, #hostname, #identity, #process_nonce, #safe_thread, #tid, #watchdog
Constructor Details
#initialize(name, config) ⇒ Capsule
Returns a new instance of Capsule.
32 33 34 35 36 37 38 39 |
# File 'lib/sidekiq/capsule.rb', line 32 def initialize(name, config) @name = name @config = config @queues = ["default"] @weights = {"default" => 0} @concurrency = config[:concurrency] @mode = :strict end |
Instance Attribute Details
#concurrency ⇒ Object
Returns the value of attribute concurrency.
26 27 28 |
# File 'lib/sidekiq/capsule.rb', line 26 def concurrency @concurrency end |
#mode ⇒ Object (readonly)
Returns the value of attribute mode.
27 28 29 |
# File 'lib/sidekiq/capsule.rb', line 27 def mode @mode end |
#name ⇒ Object (readonly)
Returns the value of attribute name.
24 25 26 |
# File 'lib/sidekiq/capsule.rb', line 24 def name @name end |
#queues ⇒ Object
Returns the value of attribute queues.
25 26 27 |
# File 'lib/sidekiq/capsule.rb', line 25 def queues @queues end |
#weights ⇒ Object (readonly)
Returns the value of attribute weights.
28 29 30 |
# File 'lib/sidekiq/capsule.rb', line 28 def weights @weights end |
Instance Method Details
#client_middleware {|@client_chain| ... } ⇒ Object
Allow the middleware to be different per-capsule. Avoid if possible and add middleware globally so all capsules share the same chains. Easier to debug that way.
80 81 82 83 84 |
# File 'lib/sidekiq/capsule.rb', line 80 def client_middleware @client_chain ||= config.client_middleware.copy_for(self) yield @client_chain if block_given? @client_chain end |
#fetcher ⇒ Object
41 42 43 44 45 46 47 |
# File 'lib/sidekiq/capsule.rb', line 41 def fetcher @fetcher ||= begin instance = (config[:fetch_class] || Sidekiq::BasicFetch).new(self) instance.setup(config[:fetch_setup]) if instance.respond_to?(:setup) instance end end |
#local_redis_pool ⇒ Object
96 97 98 99 100 |
# File 'lib/sidekiq/capsule.rb', line 96 def local_redis_pool # connection pool is lazy, it will not create connections unless you actually need them # so don't be skimpy! @redis ||= config.new_redis_pool(@concurrency, name) end |
#logger ⇒ Object
128 129 130 |
# File 'lib/sidekiq/capsule.rb', line 128 def logger config.logger end |
#lookup(name) ⇒ Object
124 125 126 |
# File 'lib/sidekiq/capsule.rb', line 124 def lookup(name) config.lookup(name) end |
#redis ⇒ Object
102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 |
# File 'lib/sidekiq/capsule.rb', line 102 def redis raise ArgumentError, "requires a block" unless block_given? redis_pool.with do |conn| retryable = true begin yield conn rescue RedisClientAdapter::BaseError => ex # 2550 Failover can cause the server to become a replica, need # to disconnect and reopen the socket to get back to the primary. # 4495 Use the same logic if we have a "Not enough replicas" error from the primary # 4985 Use the same logic when a blocking command is force-unblocked # The same retry logic is also used in client.rb if retryable && ex. =~ /READONLY|NOREPLICAS|UNBLOCKED/ conn.close retryable = false retry end raise end end end |
#redis_pool ⇒ Object
92 93 94 |
# File 'lib/sidekiq/capsule.rb', line 92 def redis_pool Thread.current[:sidekiq_redis_pool] || local_redis_pool end |
#server_middleware {|@server_chain| ... } ⇒ Object
86 87 88 89 90 |
# File 'lib/sidekiq/capsule.rb', line 86 def server_middleware @server_chain ||= config.server_middleware.copy_for(self) yield @server_chain if block_given? @server_chain end |
#stop ⇒ Object
49 50 51 |
# File 'lib/sidekiq/capsule.rb', line 49 def stop fetcher&.bulk_requeue([]) end |