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