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}"
      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
      message = metrics.map{|metric, val, ts| [metric, val, (ts||now)].join(" ") }.join("\n")
      safely do
        socket.puts(message)
        Log.info message.gsub(/\n+/, "\t")
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
graphiterb-0.1.0	lib/graphiterb/graphite_sender.rb