mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 06:37:19 -04:00
Add source_host to metrics filter event
This commit is contained in:
parent
c5d4bba42e
commit
63ef8b4f36
1 changed files with 3 additions and 1 deletions
|
@ -14,7 +14,8 @@ class LogStash::Filters::Metrics < LogStash::Filters::Base
|
|||
|
||||
def register
|
||||
require "metriks"
|
||||
|
||||
require "socket"
|
||||
|
||||
@metric_meters = Hash.new { |h,k| h[k] = Metriks.meter(k) }
|
||||
@metric_timers = Hash.new { |h,k| h[k] = Metriks.timer(k) }
|
||||
end # def register
|
||||
|
@ -33,6 +34,7 @@ class LogStash::Filters::Metrics < LogStash::Filters::Base
|
|||
|
||||
def flush
|
||||
event = LogStash::Event.new
|
||||
event.source_host = Socket.gethostname
|
||||
@metric_meters.each do |name, metric|
|
||||
event["#{name}.count"] = metric.count
|
||||
event["#{name}.rate_1m"] = metric.one_minute_rate
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue