mirror of
https://github.com/puppetlabs/vmpooler.git
synced 2026-01-26 18:08:42 -05:00
Merge pull request #208 from glennsarti/maint-rubocop
(maint) Fix rubocop violations
This commit is contained in:
Morgan Rhodes
GitHub
commit
d4a50e5e56
13 changed files with 219 additions and 254 deletions
|
|
@ -22,7 +22,7 @@ module Vmpooler
|
|||
|
||||
# Load dashboard components
|
||||
begin
|
||||
require "dashboard"
|
||||
require 'dashboard'
|
||||
rescue LoadError
|
||||
require File.expand_path(File.join(File.dirname(__FILE__), 'dashboard'))
|
||||
end
|
||||
|
|
@ -30,7 +30,7 @@ module Vmpooler
|
|||
use Vmpooler::Dashboard
|
||||
|
||||
# Load API components
|
||||
%w( helpers dashboard reroute v1 ).each do |lib|
|
||||
%w(helpers dashboard reroute v1).each do |lib|
|
||||
begin
|
||||
require "api/#{lib}"
|
||||
rescue LoadError
|
||||
|
|
|
|||
|
|
@ -1,146 +1,143 @@
|
|||
module Vmpooler
|
||||
class API
|
||||
class Dashboard < Sinatra::Base
|
||||
|
||||
# handle to the App's configuration information
|
||||
def config
|
||||
@config ||= Vmpooler::API.settings.config
|
||||
end
|
||||
|
||||
# configuration setting for server hosting graph URLs to view
|
||||
def graph_server
|
||||
return @graph_server if @graph_server
|
||||
|
||||
if config[:graphs]
|
||||
return false unless config[:graphs]['server']
|
||||
@graph_server = config[:graphs]['server']
|
||||
elsif config[:graphite]
|
||||
return false unless config[:graphite]['server']
|
||||
@graph_server = config[:graphite]['server']
|
||||
else
|
||||
false
|
||||
end
|
||||
end
|
||||
|
||||
# configuration setting for URL prefix for graphs to view
|
||||
def graph_prefix
|
||||
return @graph_prefix if @graph_prefix
|
||||
|
||||
if config[:graphs]
|
||||
return "vmpooler" unless config[:graphs]['prefix']
|
||||
@graph_prefix = config[:graphs]['prefix']
|
||||
elsif config[:graphite]
|
||||
return false unless config[:graphite]['prefix']
|
||||
@graph_prefix = config[:graphite]['prefix']
|
||||
else
|
||||
false
|
||||
end
|
||||
end
|
||||
|
||||
# what is the base URL for viewable graphs?
|
||||
def graph_url
|
||||
return false unless graph_server && graph_prefix
|
||||
@graph_url ||= "http://#{graph_server}/render?target=#{graph_prefix}"
|
||||
end
|
||||
|
||||
# return a full URL to a viewable graph for a given metrics target (graphite syntax)
|
||||
def graph_link(target = "")
|
||||
return "" unless graph_url
|
||||
graph_url + target
|
||||
end
|
||||
|
||||
|
||||
get '/dashboard/stats/vmpooler/pool/?' do
|
||||
content_type :json
|
||||
result = {}
|
||||
|
||||
Vmpooler::API.settings.config[:pools].each do |pool|
|
||||
result[pool['name']] ||= {}
|
||||
result[pool['name']]['size'] = pool['size']
|
||||
result[pool['name']]['ready'] = Vmpooler::API.settings.redis.scard('vmpooler__ready__' + pool['name'])
|
||||
class Dashboard < Sinatra::Base
|
||||
# handle to the App's configuration information
|
||||
def config
|
||||
@config ||= Vmpooler::API.settings.config
|
||||
end
|
||||
|
||||
if params[:history]
|
||||
if graph_url
|
||||
history ||= {}
|
||||
# configuration setting for server hosting graph URLs to view
|
||||
def graph_server
|
||||
return @graph_server if @graph_server
|
||||
|
||||
begin
|
||||
buffer = open(graph_link('.ready.*&from=-1hour&format=json')).read
|
||||
history = JSON.parse(buffer)
|
||||
if config[:graphs]
|
||||
return false unless config[:graphs]['server']
|
||||
@graph_server = config[:graphs]['server']
|
||||
elsif config[:graphite]
|
||||
return false unless config[:graphite]['server']
|
||||
@graph_server = config[:graphite]['server']
|
||||
else
|
||||
false
|
||||
end
|
||||
end
|
||||
|
||||
history.each do |pool|
|
||||
if pool['target'] =~ /.*\.(.*)$/
|
||||
pool['name'] = Regexp.last_match[1]
|
||||
# configuration setting for URL prefix for graphs to view
|
||||
def graph_prefix
|
||||
return @graph_prefix if @graph_prefix
|
||||
|
||||
if result[pool['name']]
|
||||
pool['last'] = result[pool['name']]['size']
|
||||
result[pool['name']]['history'] ||= Array.new
|
||||
if config[:graphs]
|
||||
return 'vmpooler' unless config[:graphs]['prefix']
|
||||
@graph_prefix = config[:graphs]['prefix']
|
||||
elsif config[:graphite]
|
||||
return false unless config[:graphite]['prefix']
|
||||
@graph_prefix = config[:graphite]['prefix']
|
||||
else
|
||||
false
|
||||
end
|
||||
end
|
||||
|
||||
pool['datapoints'].each do |metric|
|
||||
8.times do |_n|
|
||||
if metric[0]
|
||||
pool['last'] = metric[0].to_i
|
||||
result[pool['name']]['history'].push(metric[0].to_i)
|
||||
else
|
||||
result[pool['name']]['history'].push(pool['last'])
|
||||
# what is the base URL for viewable graphs?
|
||||
def graph_url
|
||||
return false unless graph_server && graph_prefix
|
||||
@graph_url ||= "http://#{graph_server}/render?target=#{graph_prefix}"
|
||||
end
|
||||
|
||||
# return a full URL to a viewable graph for a given metrics target (graphite syntax)
|
||||
def graph_link(target = '')
|
||||
return '' unless graph_url
|
||||
graph_url + target
|
||||
end
|
||||
|
||||
|
||||
get '/dashboard/stats/vmpooler/pool/?' do
|
||||
content_type :json
|
||||
result = {}
|
||||
|
||||
Vmpooler::API.settings.config[:pools].each do |pool|
|
||||
result[pool['name']] ||= {}
|
||||
result[pool['name']]['size'] = pool['size']
|
||||
result[pool['name']]['ready'] = Vmpooler::API.settings.redis.scard('vmpooler__ready__' + pool['name'])
|
||||
end
|
||||
|
||||
if params[:history]
|
||||
if graph_url
|
||||
history ||= {}
|
||||
|
||||
begin
|
||||
buffer = open(graph_link('.ready.*&from=-1hour&format=json')).read
|
||||
history = JSON.parse(buffer)
|
||||
|
||||
history.each do |pool|
|
||||
if pool['target'] =~ /.*\.(.*)$/
|
||||
pool['name'] = Regexp.last_match[1]
|
||||
|
||||
if result[pool['name']]
|
||||
pool['last'] = result[pool['name']]['size']
|
||||
result[pool['name']]['history'] ||= []
|
||||
|
||||
pool['datapoints'].each do |metric|
|
||||
8.times do |_n|
|
||||
if metric[0]
|
||||
pool['last'] = metric[0].to_i
|
||||
result[pool['name']]['history'].push(metric[0].to_i)
|
||||
else
|
||||
result[pool['name']]['history'].push(pool['last'])
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
rescue
|
||||
end
|
||||
else
|
||||
Vmpooler::API.settings.config[:pools].each do |pool|
|
||||
result[pool['name']] ||= {}
|
||||
result[pool['name']]['history'] = [Vmpooler::API.settings.redis.scard('vmpooler__ready__' + pool['name'])]
|
||||
end
|
||||
rescue
|
||||
end
|
||||
else
|
||||
Vmpooler::API.settings.config[:pools].each do |pool|
|
||||
result[pool['name']] ||= {}
|
||||
result[pool['name']]['history'] = [Vmpooler::API.settings.redis.scard('vmpooler__ready__' + pool['name'])]
|
||||
end
|
||||
end
|
||||
end
|
||||
JSON.pretty_generate(result)
|
||||
end
|
||||
|
||||
get '/dashboard/stats/vmpooler/running/?' do
|
||||
content_type :json
|
||||
result = {}
|
||||
|
||||
Vmpooler::API.settings.config[:pools].each do |pool|
|
||||
running = Vmpooler::API.settings.redis.scard('vmpooler__running__' + pool['name'])
|
||||
pool['major'] = Regexp.last_match[1] if pool['name'] =~ /^(\w+)\-/
|
||||
result[pool['major']] ||= {}
|
||||
result[pool['major']]['running'] = result[pool['major']]['running'].to_i + running.to_i
|
||||
JSON.pretty_generate(result)
|
||||
end
|
||||
|
||||
if params[:history]
|
||||
if graph_url
|
||||
begin
|
||||
buffer = open(graph_link('.running.*&from=-1hour&format=json')).read
|
||||
JSON.parse(buffer).each do |pool|
|
||||
if pool['target'] =~ /.*\.(.*)$/
|
||||
pool['name'] = Regexp.last_match[1]
|
||||
pool['major'] = Regexp.last_match[1] if pool['name'] =~ /^(\w+)\-/
|
||||
result[pool['major']]['history'] ||= Array.new
|
||||
get '/dashboard/stats/vmpooler/running/?' do
|
||||
content_type :json
|
||||
result = {}
|
||||
|
||||
for i in 0..pool['datapoints'].length
|
||||
if
|
||||
pool['datapoints'][i] &&
|
||||
pool['datapoints'][i][0]
|
||||
pool['last'] = pool['datapoints'][i][0]
|
||||
result[pool['major']]['history'][i] ||= 0
|
||||
result[pool['major']]['history'][i] = result[pool['major']]['history'][i].to_i + pool['datapoints'][i][0].to_i
|
||||
else
|
||||
result[pool['major']]['history'][i] = result[pool['major']]['history'][i].to_i + pool['last'].to_i
|
||||
Vmpooler::API.settings.config[:pools].each do |pool|
|
||||
running = Vmpooler::API.settings.redis.scard('vmpooler__running__' + pool['name'])
|
||||
pool['major'] = Regexp.last_match[1] if pool['name'] =~ /^(\w+)\-/
|
||||
result[pool['major']] ||= {}
|
||||
result[pool['major']]['running'] = result[pool['major']]['running'].to_i + running.to_i
|
||||
end
|
||||
|
||||
if params[:history]
|
||||
if graph_url
|
||||
begin
|
||||
buffer = open(graph_link('.running.*&from=-1hour&format=json')).read
|
||||
JSON.parse(buffer).each do |pool|
|
||||
if pool['target'] =~ /.*\.(.*)$/
|
||||
pool['name'] = Regexp.last_match[1]
|
||||
pool['major'] = Regexp.last_match[1] if pool['name'] =~ /^(\w+)\-/
|
||||
result[pool['major']]['history'] ||= []
|
||||
|
||||
for i in 0..pool['datapoints'].length
|
||||
if pool['datapoints'][i] && pool['datapoints'][i][0]
|
||||
pool['last'] = pool['datapoints'][i][0]
|
||||
result[pool['major']]['history'][i] ||= 0
|
||||
result[pool['major']]['history'][i] = result[pool['major']]['history'][i].to_i + pool['datapoints'][i][0].to_i
|
||||
else
|
||||
result[pool['major']]['history'][i] = result[pool['major']]['history'][i].to_i + pool['last'].to_i
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
rescue
|
||||
end
|
||||
rescue
|
||||
end
|
||||
end
|
||||
JSON.pretty_generate(result)
|
||||
end
|
||||
JSON.pretty_generate(result)
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
|
|||
|
|
@ -1,71 +1,71 @@
|
|||
module Vmpooler
|
||||
class API
|
||||
class Reroute < Sinatra::Base
|
||||
api_version = '1'
|
||||
class Reroute < Sinatra::Base
|
||||
api_version = '1'
|
||||
|
||||
get '/status/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/status")
|
||||
end
|
||||
get '/status/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/status")
|
||||
end
|
||||
|
||||
get '/summary/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/summary")
|
||||
end
|
||||
get '/summary/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/summary")
|
||||
end
|
||||
|
||||
get '/summary/:route/?:key?/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/summary/#{params[:route]}/#{params[:key]}")
|
||||
end
|
||||
get '/summary/:route/?:key?/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/summary/#{params[:route]}/#{params[:key]}")
|
||||
end
|
||||
|
||||
get '/token/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/token")
|
||||
end
|
||||
get '/token/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/token")
|
||||
end
|
||||
|
||||
post '/token/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/token")
|
||||
end
|
||||
post '/token/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/token")
|
||||
end
|
||||
|
||||
get '/token/:token/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/token/#{params[:token]}")
|
||||
end
|
||||
get '/token/:token/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/token/#{params[:token]}")
|
||||
end
|
||||
|
||||
delete '/token/:token/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/token/#{params[:token]}")
|
||||
end
|
||||
delete '/token/:token/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/token/#{params[:token]}")
|
||||
end
|
||||
|
||||
get '/vm/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/vm")
|
||||
end
|
||||
get '/vm/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/vm")
|
||||
end
|
||||
|
||||
post '/vm/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/vm")
|
||||
end
|
||||
post '/vm/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/vm")
|
||||
end
|
||||
|
||||
post '/vm/:template/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/vm/#{params[:template]}")
|
||||
end
|
||||
post '/vm/:template/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/vm/#{params[:template]}")
|
||||
end
|
||||
|
||||
get '/vm/:hostname/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/vm/#{params[:hostname]}")
|
||||
end
|
||||
get '/vm/:hostname/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/vm/#{params[:hostname]}")
|
||||
end
|
||||
|
||||
delete '/vm/:hostname/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/vm/#{params[:hostname]}")
|
||||
end
|
||||
delete '/vm/:hostname/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/vm/#{params[:hostname]}")
|
||||
end
|
||||
|
||||
put '/vm/:hostname/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/vm/#{params[:hostname]}")
|
||||
end
|
||||
put '/vm/:hostname/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/vm/#{params[:hostname]}")
|
||||
end
|
||||
|
||||
post '/vm/:hostname/snapshot/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/vm/#{params[:hostname]}/snapshot")
|
||||
end
|
||||
post '/vm/:hostname/snapshot/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/vm/#{params[:hostname]}/snapshot")
|
||||
end
|
||||
|
||||
post '/vm/:hostname/snapshot/:snapshot/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/vm/#{params[:hostname]}/snapshot/#{params[:snapshot]}")
|
||||
end
|
||||
post '/vm/:hostname/snapshot/:snapshot/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/vm/#{params[:hostname]}/snapshot/#{params[:snapshot]}")
|
||||
end
|
||||
|
||||
put '/vm/:hostname/disk/:size/?' do
|
||||
call env.merge("PATH_INFO" => "/api/v#{api_version}/vm/#{params[:hostname]}/disk/#{params[:size]}")
|
||||
put '/vm/:hostname/disk/:size/?' do
|
||||
call env.merge('PATH_INFO' => "/api/v#{api_version}/vm/#{params[:hostname]}/disk/#{params[:size]}")
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
|
|||
|
|
@ -2,18 +2,18 @@ module Vmpooler
|
|||
class DummyStatsd
|
||||
attr_reader :server, :port, :prefix
|
||||
|
||||
def initialize(params = {})
|
||||
def initialize(*)
|
||||
end
|
||||
|
||||
def increment(label)
|
||||
def increment(*)
|
||||
true
|
||||
end
|
||||
|
||||
def gauge(label, value)
|
||||
def gauge(*)
|
||||
true
|
||||
end
|
||||
|
||||
def timing(label, duration)
|
||||
def timing(*)
|
||||
true
|
||||
end
|
||||
end
|
||||
|
|
|
|||
|
|
@ -5,13 +5,13 @@ module Vmpooler
|
|||
attr_reader :server, :port, :prefix
|
||||
|
||||
def initialize(params = {})
|
||||
if params["server"].nil? || params["server"].empty?
|
||||
if params['server'].nil? || params['server'].empty?
|
||||
raise ArgumentError, "Graphite server is required. Config: #{params.inspect}"
|
||||
end
|
||||
|
||||
@server = params["server"]
|
||||
@port = params["port"] || 2003
|
||||
@prefix = params["prefix"] || "vmpooler"
|
||||
@server = params['server']
|
||||
@port = params['port'] || 2003
|
||||
@prefix = params['prefix'] || 'vmpooler'
|
||||
end
|
||||
|
||||
def increment(label)
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
%w( base vsphere ).each do |lib|
|
||||
%w(base vsphere).each do |lib|
|
||||
begin
|
||||
require "vmpooler/providers/#{lib}"
|
||||
rescue LoadError
|
||||
|
|
|
|||
|
|
@ -19,16 +19,16 @@ module Vmpooler
|
|||
# returns
|
||||
# hashtable
|
||||
# name : name of the device <---- TODO is this all?
|
||||
def vms_in_pool(pool)
|
||||
fail "#{self.class.name} does not implement vms_in_pool"
|
||||
def vms_in_pool(_pool)
|
||||
raise("#{self.class.name} does not implement vms_in_pool")
|
||||
end
|
||||
|
||||
# inputs
|
||||
# vm_name: string
|
||||
# returns
|
||||
# [String] hostname = Name of the host computer running the vm. If this is not a Virtual Machine, it returns the vm_name
|
||||
def get_vm_host(vm_name)
|
||||
fail "#{self.class.name} does not implement get_vm_host"
|
||||
def get_vm_host(_vm_name)
|
||||
raise("#{self.class.name} does not implement get_vm_host")
|
||||
end
|
||||
|
||||
# inputs
|
||||
|
|
@ -36,8 +36,8 @@ module Vmpooler
|
|||
# returns
|
||||
# [String] hostname = Name of the most appropriate host computer to run this VM. Useful for load balancing VMs in a cluster
|
||||
# If this is not a Virtual Machine, it returns the vm_name
|
||||
def find_least_used_compatible_host(vm_name)
|
||||
fail "#{self.class.name} does not implement find_least_used_compatible_host"
|
||||
def find_least_used_compatible_host(_vm_name)
|
||||
raise("#{self.class.name} does not implement find_least_used_compatible_host")
|
||||
end
|
||||
|
||||
# inputs
|
||||
|
|
@ -45,8 +45,8 @@ module Vmpooler
|
|||
# dest_host_name: string (Name of the host to migrate `vm_name` to)
|
||||
# returns
|
||||
# [Boolean] Returns true on success or false on failure
|
||||
def migrate_vm_to_host(vm_name, dest_host_name)
|
||||
fail "#{self.class.name} does not implement migrate_vm_to_host"
|
||||
def migrate_vm_to_host(_vm_name, _dest_host_name)
|
||||
raise("#{self.class.name} does not implement migrate_vm_to_host")
|
||||
end
|
||||
|
||||
# inputs
|
||||
|
|
@ -61,8 +61,8 @@ module Vmpooler
|
|||
# [Time] boottime = Time when the VM was created/booted
|
||||
# [String] powerstate = Current power state of a VM. Valid values (as per vCenter API)
|
||||
# - 'PoweredOn','PoweredOff'
|
||||
def get_vm(vm_name)
|
||||
fail "#{self.class.name} does not implement get_vm"
|
||||
def get_vm(_vm_name)
|
||||
raise("#{self.class.name} does not implement get_vm")
|
||||
end
|
||||
|
||||
# inputs
|
||||
|
|
@ -70,8 +70,8 @@ module Vmpooler
|
|||
# new_vmname : string Name the new VM should use
|
||||
# returns
|
||||
# Hashtable of the VM as per get_vm
|
||||
def create_vm(pool,new_vmname)
|
||||
fail "#{self.class.name} does not implement create_vm"
|
||||
def create_vm(_pool, _new_vmname)
|
||||
raise("#{self.class.name} does not implement create_vm")
|
||||
end
|
||||
|
||||
# inputs
|
||||
|
|
@ -79,8 +79,8 @@ module Vmpooler
|
|||
# pool: string
|
||||
# returns
|
||||
# boolean : true if success, false on error
|
||||
def destroy_vm(vm_name,pool)
|
||||
fail "#{self.class.name} does not implement destroy_vm"
|
||||
def destroy_vm(_vm_name, _pool)
|
||||
raise("#{self.class.name} does not implement destroy_vm")
|
||||
end
|
||||
|
||||
# inputs
|
||||
|
|
@ -89,8 +89,8 @@ module Vmpooler
|
|||
# timeout: int (Seconds)
|
||||
# returns
|
||||
# result: boolean
|
||||
def is_vm_ready?(vm,pool,timeout)
|
||||
fail "#{self.class.name} does not implement is_vm_ready?"
|
||||
def vm_ready?(_vm, _pool, _timeout)
|
||||
raise("#{self.class.name} does not implement vm_ready?")
|
||||
end
|
||||
|
||||
# inputs
|
||||
|
|
@ -100,7 +100,6 @@ module Vmpooler
|
|||
def vm_exists?(vm)
|
||||
!get_vm(vm).nil?
|
||||
end
|
||||
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
|
|||
|
|
@ -1,16 +1,14 @@
|
|||
module Vmpooler
|
||||
class PoolManager
|
||||
class Provider
|
||||
class VSphere < Vmpooler::PoolManager::Provider::Base
|
||||
|
||||
class VSphere < Vmpooler::PoolManager::Provider::Base
|
||||
def initialize(options)
|
||||
super(options)
|
||||
super(options)
|
||||
end
|
||||
|
||||
def name
|
||||
'vsphere'
|
||||
end
|
||||
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
|
|||
|
|
@ -6,30 +6,30 @@ module Vmpooler
|
|||
attr_reader :server, :port, :prefix
|
||||
|
||||
def initialize(params = {})
|
||||
if params["server"].nil? || params["server"].empty?
|
||||
if params['server'].nil? || params['server'].empty?
|
||||
raise ArgumentError, "Statsd server is required. Config: #{params.inspect}"
|
||||
end
|
||||
|
||||
host = params["server"]
|
||||
@port = params["port"] || 8125
|
||||
@prefix = params["prefix"] || 'vmpooler'
|
||||
host = params['server']
|
||||
@port = params['port'] || 8125
|
||||
@prefix = params['prefix'] || 'vmpooler'
|
||||
@server = ::Statsd.new(host, @port)
|
||||
end
|
||||
|
||||
def increment(label)
|
||||
server.increment(prefix + "." + label)
|
||||
server.increment(prefix + '.' + label)
|
||||
rescue => err
|
||||
$stderr.puts "Failure incrementing #{prefix}.#{label} on statsd server [#{server}:#{port}]: #{err}"
|
||||
end
|
||||
|
||||
def gauge(label, value)
|
||||
server.gauge(prefix + "." + label, value)
|
||||
server.gauge(prefix + '.' + label, value)
|
||||
rescue => err
|
||||
$stderr.puts "Failure updating gauge #{prefix}.#{label} on statsd server [#{server}:#{port}]: #{err}"
|
||||
end
|
||||
|
||||
def timing(label, duration)
|
||||
server.timing(prefix + "." + label, duration)
|
||||
server.timing(prefix + '.' + label, duration)
|
||||
rescue => err
|
||||
$stderr.puts "Failure updating timing #{prefix}.#{label} on statsd server [#{server}:#{port}]: #{err}"
|
||||
end
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue