class LogStash::Filters::Influxdb
Public Instance Methods
filter(event)
click to toggle source
# File lib/logstash/filters/influxdb.rb, line 22 def filter(event) point = InfluxParser.parse_point(event.get(@source),{ :parse_types => @parse_types, :time_format => @time_format }) if point event.set(@target, point) else event.set(@target, {'_influxparseerror' => true }) end # filter_matched should go in the last line of our successful code filter_matched(event) end
register()
click to toggle source
# File lib/logstash/filters/influxdb.rb, line 17 def register # Add instance variables end