Class: SidekiqActiveRecordShard::Client

Inherits:
Object
  • Object
show all
Includes:
Sidekiq::ClientMiddleware
Defined in:
lib/sidekiq-activerecord-shard/middleware.rb

Instance Method Summary collapse

Instance Method Details

#call(_jobclass, job, _queue, _redis) ⇒ Object 



9
10
11
12
13
14
 
# File 'lib/sidekiq-activerecord-shard/middleware.rb', line 9

def call(_jobclass, job, _queue, _redis)
  # Store shard value in Job arguments
  job["shard"] ||= SidekiqActiveRecordShard.config.selected_shard.call

  yield
end