class DashingContrib::Kue::Client

Attributes

endpoint[R]

Public Class Methods

new(options = {}) click to toggle source

Creates a new Kue Client Arguments:

endpoint

endpoint of Kue web interface

# File lib/dashing-contrib/bottles/kue/client.rb, line 12
def initialize(options = {})
  @endpoint = options[:endpoint]
end

Public Instance Methods

stats() click to toggle source

Returns a stats summary of Kue status in following format

Tries to transform from camalCase JSON key to ruby friendly symbal underscore format

{
  :inactive_count: 235,
  :complete_count: 29426,
  :active_count: 4,
  :failed_count: 11,
  :delayed_count: 0,
  :work_time: 778205330
}
# File lib/dashing-contrib/bottles/kue/client.rb, line 30
def stats
  payload = {}
  get_request('stats').each do |key, value|
    payload[:"#{key.underscore}"] = value
  end
  payload
end

Private Instance Methods

get_request(uri) click to toggle source
# File lib/dashing-contrib/bottles/kue/client.rb, line 39
def get_request(uri)
  response = RestClient.get("#{endpoint}/#{uri}")
  MultiJson.load(response.body)
end