Class: Autoscaler::Sidekiq::Activity

Inherits:

Object

• Object
• Autoscaler::Sidekiq::Activity

Defined in:

lib/autoscaler/sidekiq/activity.rb

Overview

Tracks activity timeouts using Sidekiq’s redis connection

Instance Method Summary

• #idle!(queue) ⇒ Object

  Record that a queue is idle and timed out - mostly for test support.

• #idle?(queues) ⇒ boolean

  Have the watched queues timed out?.

• #initialize(timeout) ⇒ Activity constructor

  A new instance of Activity.

• #working!(queue) ⇒ Object

  Record that a queue has activity.

Constructor Details

#initialize(timeout) ⇒ Activity

Returns a new instance of Activity.

Parameters:

• timeout (Numeric) —

  number of seconds to wait before shutdown

# File 'lib/autoscaler/sidekiq/activity.rb', line 8

def initialize(timeout)
  @timeout = timeout
end

Instance Method Details

#idle!(queue) ⇒ Object

Record that a queue is idle and timed out - mostly for test support

Parameters:

• queue (String)

# File 'lib/autoscaler/sidekiq/activity.rb', line 20

def idle!(queue)
  active_at queue, Time.now - timeout*2
end

#idle?(queues) ⇒ boolean

Have the watched queues timed out?

Parameters:

• queues (Array[String]) —

  list of queues to monitor to determine if there is work left

Returns:

• (boolean)

# File 'lib/autoscaler/sidekiq/activity.rb', line 27

def idle?(queues)
  idle_time(queues) > timeout
end

#working!(queue) ⇒ Object

Record that a queue has activity

Parameters:

• queue (String)

# File 'lib/autoscaler/sidekiq/activity.rb', line 14

def working!(queue)
  active_at queue, Time.now
end