diff options
| author | Jamie Nguyen <jamie.nguyen@bytemark.co.uk> | 2017-09-20 07:54:35 +0100 | 
|---|---|---|
| committer | Jamie Nguyen <jamie.nguyen@bytemark.co.uk> | 2017-09-20 07:54:35 +0100 | 
| commit | 5bfbf71c0b08647ca93460a2eda01f3221716003 (patch) | |
| tree | 964267e4abdc80685a5f7bdceeae5687d0b3bdd7 /lib | |
| parent | 005013d98d742989d3c000b04054e15bb0482a69 (diff) | |
| parent | 99394d4a174239ece0aeba5e0a1a5755fd2ec45b (diff) | |
Merge branch '19-user-agent' into 'master'
Resolve "Can custodian send a user agent string please"
Closes #19
See merge request !13
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/custodian/alerts/graphite.rb | 24 | ||||
| -rw-r--r-- | lib/custodian/protocoltest/http.rb | 3 | 
2 files changed, 22 insertions, 5 deletions
| diff --git a/lib/custodian/alerts/graphite.rb b/lib/custodian/alerts/graphite.rb index 0244047..cca5ece 100644 --- a/lib/custodian/alerts/graphite.rb +++ b/lib/custodian/alerts/graphite.rb @@ -1,4 +1,5 @@  require 'socket' +require 'timeout'  #  #  The graphite-alerter. @@ -61,12 +62,25 @@ module Custodian          payload = "custodian.#{test}.#{host}.test_duration_ms #{ms} #{Time.now.to_i}"          # -        #  Send via UDP. +        #  Send metrics via TCP.          # -        socket = UDPSocket.new -        socket.send(payload, 0, @target, 2003) -        socket.close - +        begin +          Timeout.timeout(10) do +            begin +              socket = TCPSocket.new(@target,2003) +              puts payload +              socket.write(payload) +              socket.flush +              socket.close +            rescue Errno::ENETUNREACH +              puts("Metrics host unreachable: #{e}") +            rescue StandardError => e +              puts("Error submitting metrics: #{e}") +            end +          end +        rescue Timeout::Error +          puts('Timeout submitting metrics') +        end        end        register_alert_type 'graphite' diff --git a/lib/custodian/protocoltest/http.rb b/lib/custodian/protocoltest/http.rb index 0bf1a68..5f013df 100644 --- a/lib/custodian/protocoltest/http.rb +++ b/lib/custodian/protocoltest/http.rb @@ -360,6 +360,9 @@ module Custodian            c = Curl::Easy.new(test_url) +          # setup a user-agent. +          c.headers["User-Agent"] = "custodian/protocol-tester" +            c.resolve_mode = resolve_mode            # | 
