class Riemann::Tools::PostgreSQSMetrics

Public Class Methods

new() click to toggle source
# File bin/riemann-sqs-metrics, line 16
def initialize
    @sqs = Fog::AWS::SQS.new(:aws_access_key_id => opts[:aws_access_key_id],
                                  :aws_secret_access_key => opts[:aws_secret_access_key_id])

end

Public Instance Methods

tick() click to toggle source
# File bin/riemann-sqs-metrics, line 22
def tick
  results = @sqs.get_queue_attributes(opts[:queue_url], opts[:metric])
  if results
    data = {}
    results.body["Attributes"].each do |key, value|
      data = {
        :metric       => value.to_f,
        :host         => opts[:queue_url],
        :state        => 'ok',
        :description  => key,
        :tags         => ['sqs-metrics'],
        :service      => opts[:service]
      }
      report(data)
    end
  end
end