Sha256: f29354067217ddb0a2623396170c64817816f855f57d15509503c47234aed937
Contents?: true
Size: 1.34 KB
Versions: 6
Compression:
Stored size: 1.34 KB
Contents
# encoding: utf-8
require "logstash/inputs/tcp"
require "logstash/namespace"
require "logstash/timestamp"
# Receive graphite metrics. This plugin understands the text-based graphite
# carbon protocol. Both `N` and `specific-timestamp` forms are supported, example:
# [source,ruby]
# mysql.slow_query.count 204 N
# haproxy.live_backends 7 1364608909
#
# `N` means `now` for a timestamp. This plugin also supports having the time
# specified in the metric payload:
#
# For every metric received from a client, a single event will be emitted with
# the metric name as the field (like `mysql.slow_query.count`) and the metric
# value as the field's value.
class LogStash::Inputs::Graphite < LogStash::Inputs::Tcp
config_name "graphite"
public
def run(output_queue)
@queue = output_queue
# pass self as output_queue to super Tcp#run - this is a hack so that the << calls in
# Tcp will actually call the << method defined below. This is twisted :P
super(self)
end
# This is a silly hack to make the superclass (Tcp) give us a finished event
# so that we can parse it accordingly.
def <<(event)
name, value, time = event.get("message").split(" ")
event.set(name, value.to_f)
if time != "N"
event.timestamp = LogStash::Timestamp.at(time.to_i)
end
@queue << event
end
end # class LogStash::Inputs::Graphite
Version data entries
6 entries across 6 versions & 1 rubygems