gistfile1

#!/usr/bin/env ruby

require_relative 'lib/flume/metrics'
require 'trollop'

opts = Trollop.options do
  opt :warn, "Warning threshold",  :type => Integer, :default => 100
  opt :crit, "Critical threshold", :type => Integer, :default => 1000
  opt :url,  "Flume end point",    :type => String,  :default => "http://localhost:8080/metrics"
end

def channel_sizes(metrics)
  metrics.channels.each do |channel|
    channel.attribute('ChannelSize')
  end
end

metrics = Flume::Metrics.new(opts[:url])

max_channel_size = channel_sizes.max