Module: SidekiqUniqueJobs::Connection

Included in:
SidekiqUniqueJobs, BatchDelete, Lock, Locksmith, Orphans::Reaper, UpgradeLocks
Defined in:
lib/sidekiq_unique_jobs/connection.rb

Overview

Shared module for dealing with redis connections

Author:

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(base) ⇒ Object 



8
9
10
 
# File 'lib/sidekiq_unique_jobs/connection.rb', line 8

def self.included(base)
  base.send(:extend, self)
end

Instance Method Details

#redis(r_pool = nil, &block) ⇒ Sidekiq::RedisConnection, ConnectionPool

Creates a connection to redis

Returns:

  • (Sidekiq::RedisConnection, ConnectionPool) —

    a connection to redis



14
15
16
17
18
19
20
21
 
# File 'lib/sidekiq_unique_jobs/connection.rb', line 14

def redis(r_pool = nil, &block)
  r_pool ||= defined?(redis_pool) ? redis_pool : r_pool
  if r_pool
    r_pool.with(&block)
  else
    Sidekiq.redis(&block)
  end
end