Class: Logging::Appenders::Riemann

Inherits:
Logging::Appender
  • Object
show all
Defined in:
lib/logging/appenders/riemann.rb

Constant Summary collapse

DEFAULT_URI = 
"udp://localhost:5555"

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name, options = {}) ⇒ Riemann

Returns a new instance of Riemann.



17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/logging/appenders/riemann.rb', line 17

def initialize(name,options={})
  uri=URI.parse(options[:uri] || DEFAULT_URI)
  @mapper=options[:mapper] || lambda do |hash|
  end
  @riemann_host= uri.host
  @riemann_port = uri.port
  @riemann_client=::Riemann::Client.new(:host => @riemann_host,
                                        :port => @riemann_port)
  @host=options.delete(:host) || Socket.gethostname
  super
end

Instance Attribute Details

#riemann_client ⇒ Object (readonly)

Parameters:

  • option —

    accepts :uri like “udp://host:port”, :host



15
16
17
 
# File 'lib/logging/appenders/riemann.rb', line 15

def riemann_client
  @riemann_client
end

#riemann_host ⇒ Object (readonly)

Parameters:

  • option —

    accepts :uri like “udp://host:port”, :host



15
16
17
 
# File 'lib/logging/appenders/riemann.rb', line 15

def riemann_host
  @riemann_host
end

#riemann_port ⇒ Object (readonly)

Parameters:

  • option —

    accepts :uri like “udp://host:port”, :host



15
16
17
 
# File 'lib/logging/appenders/riemann.rb', line 15

def riemann_port
  @riemann_port
end

Instance Method Details

#event2riemann_hash(logging_event) ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
 
# File 'lib/logging/appenders/riemann.rb', line 34

def event2riemann_hash(logging_event)
  riemann_event=if logging_event.data.kind_of?(Hash)
                  logging_event.data.dup
                else
                  {:description => msg2str(logging_event.data)}
                end


  @mapper.call(riemann_event)
  riemann_event[:sate] ||= ::Logging::LNAMES[logging_event.level]
  riemann_event[:host] ||= @host
  riemann_event[:service] ||= @name
  riemann_event[:description] ||= logging_event.data[:message]
  riemann_event[:time] ||= logging_event.time.to_i

  #we don't overrdide given things from any context (mdc/ndc)
  Logging.mdc.context.each do |key, value|
    riemann_event[key] ||= value
  end

  Logging.ndc.context.each do |ctx|
    if ctx.respond_to?(:each)
      ctx.each do |key, value|
        riemann_event[key] ||= value
      end
    else
      riemann_event[ctx] ||= true #
    end
  end

  riemann_event
end

#msg2str(msg) ⇒ Object 



67
68
69
70
71
72
73
74
75
76
77
 
# File 'lib/logging/appenders/riemann.rb', line 67

def msg2str(msg)
  case msg
    when ::String
      msg
    when ::Exception
      "#{ msg.message } (#{ msg.class })\n" <<
          (msg.backtrace || []).join("\n")
    else
      msg.inspect
  end
end

#write(event) ⇒ Object 



30
31
32
 
# File 'lib/logging/appenders/riemann.rb', line 30

def write(event)
  self.riemann_client << event2riemann_hash(event)
end