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