Module: Sidekiq::LimitFetch::Global::Monitor

Extended by:
Monitor
Included in:
Monitor
Defined in:
lib/sidekiq/limit_fetch/global/monitor.rb

Constant Summary collapse

HEARTBEAT_NAMESPACE = 
'heartbeat:'
PROCESSOR_NAMESPACE = 
'processor:'
HEARTBEAT_TTL = 
90
REFRESH_TIMEOUT = 
60

Instance Method Summary collapse

Instance Method Details

#start!(ttl = HEARTBEAT_TTL, timeout = REFRESH_TIMEOUT) ⇒ Object 



11
12
13
14
15
16
17
18
19
 
# File 'lib/sidekiq/limit_fetch/global/monitor.rb', line 11

def start!(ttl=HEARTBEAT_TTL, timeout=REFRESH_TIMEOUT)
  Thread.new do
    loop do
      update_heartbeat ttl
      invalidate_old_processors
      sleep timeout
    end
  end
end