Sha256: 5cfbd030abddc8e3e8eefa41abc1b032472739ed74ef988addb9b0e5f47530fc
Contents?: true
Size: 576 Bytes
Versions: 10
Compression:
Stored size: 576 Bytes
Contents
module Sidekiq
class Queue
extend LimitFetch::Singleton, Forwardable
attr_reader :rname
def_delegators :lock,
:limit, :limit=,
:process_limit, :process_limit=,
:acquire, :release,
:pause, :unpause,
:block, :unblock,
:paused?, :blocking?,
:unblocked, :block_except,
:probed, :busy,
:increase_busy, :decrease_busy,
:local_busy?, :explain,
:remove_locks_except!
def lock
@lock ||= LimitFetch::Global::Semaphore.new name
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems