Sha256: 6ca66118480b49b6a6db9de825d00713f6f438f3665eefd8a603c31ca52afe59

Contents?: true

Size: 521 Bytes

Versions: 9

Compression:

Stored size: 521 Bytes

Contents

require 'rubygems'
require 'riemann/client'

c = Riemann::Client.new(
  host: config[:host] || 'localhost',
  port: config[:port] || 5555,
)

hostname = config[:hostname] || Socket.gethostname

->(metrics) {
  c.send_maybe_recv(Riemann::Message.new(:events =>
    metrics.keys.map {|k|
      v = metrics[k]
      v = v.respond_to?(:to_f) ? v.to_f : v ? 1 : 0
      Riemann::Event.new(
        host:    hostname,
        service: k, metric:  v,
        # TODO tags,description,ttl,state configurable?
      )
    }
  ))
}

Version data entries

9 entries across 9 versions & 1 rubygems

Version Path
panoptimon-0.4.5 plugins/riemann_stream/riemann_stream.rb
panoptimon-0.4.4 plugins/riemann_stream/riemann_stream.rb
panoptimon-0.4.2 plugins/riemann_stream/riemann_stream.rb
panoptimon-0.4.1 plugins/riemann_stream/riemann_stream.rb
panoptimon-0.4.0 plugins/riemann_stream/riemann_stream.rb
panoptimon-0.3.0 plugins/riemann_stream/riemann_stream.rb
panoptimon-0.2.0 plugins/riemann_stream/riemann_stream.rb
panoptimon-0.1.0 plugins/riemann_stream/riemann_stream.rb
panoptimon-0.0.2 plugins/riemann_stream/riemann_stream.rb