Module: SidekiqUniqueJobs

Defined in:
lib/sidekiq-unique-jobs.rb,
lib/sidekiq_unique_jobs/config.rb,
lib/sidekiq_unique_jobs/version.rb,
lib/sidekiq_unique_jobs/connectors.rb,
lib/sidekiq_unique_jobs/inline_testing.rb,
lib/sidekiq_unique_jobs/payload_helper.rb,
lib/sidekiq_unique_jobs/connectors/testing.rb,
lib/sidekiq_unique_jobs/connectors/redis_pool.rb,
lib/sidekiq_unique_jobs/connectors/sidekiq_redis.rb,
lib/sidekiq_unique_jobs/middleware/client/unique_jobs.rb,
lib/sidekiq_unique_jobs/middleware/server/unique_jobs.rb,
lib/sidekiq_unique_jobs/middleware/client/strategies/unique.rb,
lib/sidekiq_unique_jobs/middleware/client/strategies/testing_inline.rb

Defined Under Namespace

Modules: Connectors, Middleware Classes: Config, PayloadHelper

Constant Summary collapse

VERSION = 
'3.0.13'

Class Method Summary collapse

Class Method Details

.config ⇒ Object 



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

def config
  @config ||= Config.new(
    unique_prefix: 'sidekiq_unique',
    unique_args_enabled: false,
    default_expiration: 30 * 60,
    default_unlock_order: :after_yield
  )
end

.configure {|config| ... } ⇒ Object

Yields:



27
28
29
 
# File 'lib/sidekiq-unique-jobs.rb', line 27

def configure
  yield config
end

.redis_mock ⇒ Object 



9
10
11
 
# File 'lib/sidekiq_unique_jobs/inline_testing.rb', line 9

def self.redis_mock
  @redis_mock ||= MockRedis.new
end

.unique_args_enabled? ⇒ Boolean

Returns:

  • (Boolean) 


23
24
25
 
# File 'lib/sidekiq-unique-jobs.rb', line 23

def unique_args_enabled?
  config.unique_args_enabled
end

.worker_class_constantize(worker_class) ⇒ Object

Attempt to constantize a string worker_class argument, always failing back to the original argument.



33
34
35
36
37
38
 
# File 'lib/sidekiq-unique-jobs.rb', line 33

def worker_class_constantize(worker_class)
  return worker_class unless worker_class.is_a?(String)
  worker_class.constantize
rescue NameError
  worker_class
end