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

# 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

# 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?

# 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

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

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