Sha256: 19687007df7e2eeeebceecd0aef8beea7ffc7009ae83baf814679cff637c0c22
Contents?: true
Size: 1.27 KB
Versions: 4
Compression:
Stored size: 1.27 KB
Contents
module Graphiterb # # @example: # # in initialize, perhaps # self.sender = GraphiteSender # # # ... somewhere else ... # sender.send( ['webserver.pages', pages_this_hour], ['webserver.errors', errors_this_hour] ) # class GraphiteSender def initialize open! end def open! begin Log.warn "Connecting to server #{Settings.carbon_server} port #{Settings.carbon_port}" @socket = TCPSocket.new(Settings.carbon_server, Settings.carbon_port) rescue StandardError => e Log.warn "Couldn't connect to server #{Settings.carbon_server} port #{Settings.carbon_port}: #{e.class} #{e}" $stderr end end def socket @socket ||= open! end def safely &block begin block.call rescue StandardError => e Log.warn "Sleeping #{Settings.on_error_delay}: #{e.class} #{e}" sleep Settings.on_error_delay @socket = nil return nil end end def timestamp Time.now.to_i end def send *metrics now = timestamp safely do message = metrics.map{|metric, val, ts| [metric, val, (ts||now)].join(" ") }.join("\n")+"\n" socket.puts(message) Log.info message.gsub(/\n+/, "\t") end end end end
Version data entries
4 entries across 4 versions & 1 rubygems