Module: Workarea::Configuration::Sidekiq

Extended by:
Sidekiq
Included in:
Sidekiq
Defined in:
lib/workarea/configuration/sidekiq.rb

Instance Method Summary collapse

Instance Method Details

#concurrency ⇒ Object 



84
85
86
87
88
89
 
# File 'lib/workarea/configuration/sidekiq.rb', line 84

def concurrency
  value = ENV['WORKAREA_SIDEKIQ_CONCURRENCY'].presence ||
    ::Sidekiq::DEFAULTS[:concurrency]

  value.to_i
end

#configure_plugins! ⇒ Object 



65
66
67
68
69
70
71
72
73
74
75
76
77
78
 
# File 'lib/workarea/configuration/sidekiq.rb', line 65

def configure_plugins!
  ActiveJob::Base.queue_adapter = :sidekiq

  if ::Sidekiq.const_defined?('Testing') && ::Sidekiq::Testing.inline?
    ::Sidekiq.configure_client do |config|
      config.client_middleware do |chain|
        chain.remove SidekiqUniqueJobs::Client::Middleware
      end
    end
  end

  ::Sidekiq::Callbacks.assert_valid_config!
  ::Sidekiq::Throttled.setup!
end

#configure_workarea! ⇒ Object 



26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
 
# File 'lib/workarea/configuration/sidekiq.rb', line 26

def configure_workarea!
  ::Sidekiq::Logging.logger = Logger.new(
    File.join(Rails.root, 'log', 'sidekiq.log')
  )

  ::Sidekiq.default_worker_options = {
    log_duplicate_payload: true
  }

  ::Sidekiq.configure_server do |config|
    config.server_middleware do |chain|
      chain.add I18nServerMiddleware
      chain.add QueryCacheMiddleware
      chain.add AuditLogServerMiddleware
      chain.add ReleaseServerMiddleware
    end

    config.client_middleware do |chain|
      chain.add I18nClientMiddleware
      chain.add AuditLogClientMiddleware
    end

    config.redis = {
      url: Configuration::Redis.persistent.to_url,
      size: pool_size,
      pool_timeout: pool_timeout
    }
  end

  ::Sidekiq.configure_client do |config|
    config.client_middleware do |chain|
      chain.add Workarea::I18nClientMiddleware
      chain.add AuditLogClientMiddleware
    end

    config.redis = { url: Configuration::Redis.persistent.to_url }
  end
end

#load ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/workarea/configuration/sidekiq.rb', line 6

def load
  require_dependency "#{Workarea::Core::Engine.root}/app/middleware/workarea/i18n_client_middleware"
  require_dependency "#{Workarea::Core::Engine.root}/app/middleware/workarea/i18n_server_middleware"
  require_dependency "#{Workarea::Core::Engine.root}/app/middleware/workarea/audit_log_client_middleware"
  require_dependency "#{Workarea::Core::Engine.root}/app/middleware/workarea/audit_log_server_middleware"
  require_dependency "#{Workarea::Core::Engine.root}/app/middleware/workarea/release_server_middleware"
  require_dependency "#{Workarea::Core::Engine.root}/app/middleware/workarea/query_cache_middleware"

  unless manually_configured?
    ::Sidekiq.options.merge!(
      pidfile: pidfile,
      concurrency: concurrency,
      timeout: timeout,
      queues: queues
    )
  end

  configure_workarea!
end

#manually_configured? ⇒ Boolean

Returns:

  • (Boolean) 


115
116
117
118
119
 
# File 'lib/workarea/configuration/sidekiq.rb', line 115

def manually_configured?
  %w[config/sidekiq.yml config/sidekiq.yml.erb].any? do |filename|
    File.exist?(Rails.root.join(filename))
  end
end

#pidfile ⇒ Object 



80
81
82
 
# File 'lib/workarea/configuration/sidekiq.rb', line 80

def pidfile
  ENV['WORKAREA_SIDEKIQ_PIDFILE'].presence || './tmp/pids/sidekiq.pid'
end

#pool_size ⇒ Object 



104
105
106
107
108
109
 
# File 'lib/workarea/configuration/sidekiq.rb', line 104

def pool_size
  value = ENV['WORKAREA_SIDEKIQ_POOL_SIZE'].presence ||
    ::Sidekiq.options[:concurrency] + 5

  value.to_i
end

#pool_timeout ⇒ Object 



111
112
113
 
# File 'lib/workarea/configuration/sidekiq.rb', line 111

def pool_timeout
  (ENV['WORKAREA_SIDEKIQ_POOL_TIMEOUT'].presence || 1).to_i
end

#queues ⇒ Object 



99
100
101
102
 
# File 'lib/workarea/configuration/sidekiq.rb', line 99

def queues
  ENV['WORKAREA_SIDEKIQ_QUEUES'].to_s.split(',').presence ||
    %w(releases high default low mailers)
end

#timeout ⇒ Object 



91
92
93
94
95
96
97
 
# File 'lib/workarea/configuration/sidekiq.rb', line 91

def timeout
  value = ENV['WORKAREA_SIDEKIQ_TIMEOUT'].presence ||
    ENV['WORKAREA_SIDEKIQ_DEFAULT_TIMEOUT'].presence || # legacy
    ::Sidekiq::DEFAULTS[:timeout]

  value.to_i
end