Sha256: 7fa8176ed63a4fa8b2245d93b6cbb1f562a1c057522f92e9c0fa18c1ff6ac71e
Contents?: true
Size: 1.17 KB
Versions: 6
Compression:
Stored size: 1.17 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
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["message"].split(" ")
event[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