class Fluent::Helper::PluginSpec::Driver::BatchPitcher
Public Class Methods
new(parent, tag, time=Time.now.to_i)
click to toggle source
# File lib/fluent/helper/plugin_spec.rb, line 80 def initialize(parent, tag, time=Time.now.to_i) @parent = parent @tag = tag @time = time end
Public Instance Methods
pitch(record, time=nil)
click to toggle source
# File lib/fluent/helper/plugin_spec.rb, line 85 def pitch(record, time=nil) @parent.pitch(@tag, time ? time : @time, record) end
pitches(es)
click to toggle source
# File lib/fluent/helper/plugin_spec.rb, line 89 def pitches(es) @parent.pitches(@tag, es) end