Class
Sidekiq::LimitFetch::Global::Semaphore
In:
lib/sidekiq/limit_fetch/global/semaphore.rb
Parent:
Object
Methods
acquire
block
block_except
blocking?
busy
busy_processes
decrease_busy
decrease_local_busy
explain
increase_busy
increase_local_busy
limit
limit=
limit_changed?
local_busy?
new
pause
pause_for_ms
paused?
probed
probed_processes
process_limit
process_limit=
release
remove_lock!
remove_locks_except!
unblock
unpause
Constants
PREFIX
=
'limit_fetch'
Attributes
local_busy
[R]
Public Class methods
new
(name)
Public Instance methods
acquire
()
block
()
block_except
(*queues)
blocking?
()
busy
()
busy_processes
()
decrease_busy
()
decrease_local_busy
()
explain
()
increase_busy
()
increase_local_busy
()
limit
()
limit=
(value)
limit_changed?
()
local_busy?
()
pause
()
pause_for_ms
(ms)
paused?
()
probed
()
probed_processes
()
process_limit
()
process_limit=
(value)
release
()
remove_lock!
(process)
remove_locks_except!
(processes)
unblock
()
unpause
()
[Validate]