Contents

# +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
# Send a notice to a SENSU client socket, port 3030 on 'localhost' only.
# +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
# [mandatory]
# check_name    - a unique check name
#
# [optional]
# status_code   - status codes used are 0 for OK, 1 for WARNING, 2 for CRITICAL, and 3 or greater to indicate UNKNOWN or CUSTOM.
# handler       - default handler
#

CONTACT_DEPS[:sensu] = ['json']
CONTACT_DEPS[:sensu].each do |d|
  require d
end

module God
  module Contacts
    class Sensu < Contact
      class << self
        attr_accessor :check_name, :status_code, :handler, :host, :port
      end

      self.status_code = 2
      self.handler = 'default'
      self.host = 'localhost'
      self.port = 3030

      def valid?
        valid = true
        valid &= complain("Attribute 'check_name' must be specified", self) unless arg(:check_name)
        valid
      end

      attr_accessor :check_name, :status_code, :handler, :host, :port

      def sensu_client_socket(msg)
        u = UDPSocket.new
        u.send("#{msg}\n", 0, arg(:host).nil? ? host : arg(:host), arg(:port).nil? ? port : arg(:port))
        u.close
      end

      def notify(message, time, priority, category, host)
        data = {
          category: category,
          message: message,
          priority: priority,
          host: host,
          time: time
        }
        parcel = {
          'name' => arg(:check_name),
          'status' => arg(:status_code).nil? ? status_code : arg(:status_code),
          'output' => data.to_json,
          'handler' => arg(:handler).empty? ? handler : arg(:handler),
          'executed' => Time.now.to_i
        }
        sensu_client_socket parcel.to_json
        self.info = "notified sensu: #{arg(:check_name)}"
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
resurrected_god-1.0.0	lib/god/contacts/sensu.rb