bin/riemann-bench in riemann-tools-0.1.1 vs bin/riemann-bench in riemann-tools-0.1.2

- old
+ new

@@ -1,21 +1,22 @@ #!/usr/bin/env ruby # Connects to a server (first arg) and populates it with a constant stream of # events for testing. +require 'rubygems' require 'riemann/client' require 'pp' class Riemann::Bench attr_accessor :client, :hosts, :services, :states def initialize @hosts = [nil] + (0...10).map { |i| "host#{i}" } @hosts = %w(a b c d e f g h i j) @services = %w(test1 test2 test3 foo bar baz xyzzy attack cat treat) @states = {} - @client = Riemann::Client.new(host: (ARGV.first || 'localhost')) + @client = Riemann::Client.new(:host => (ARGV.first || 'localhost')) end def evolve(state) m = state[:metric] + (rand - 0.5) * 0.1 m = [[0,m].max, 1].min @@ -28,15 +29,15 @@ when 0.9..1.0 'critical' end { - metric: m, - state: s, - host: state[:host], - service: state[:service], - description: "at #{Time.now}" + :metric => m, + :state => s, + :host => state[:host], + :service => state[:service], + :description => "at #{Time.now}" } end def tick # pp @states @@ -54,14 +55,14 @@ end def start hosts.product(services).each do |host, service| states[[host, service]] = { - metric: 0.5, - state: 'ok', - description: "Starting up", - host: host, - service: service + :metric => 0.5, + :state => 'ok', + :description => "Starting up", + :host => host, + :service => service } end end end