# File lib/fluent/plugin/in_dummy.rb, line 42 def configure(conf) super @increment_value = 0 @dummy_index = 0 end
# File lib/fluent/plugin/in_dummy.rb, line 77 def emit(num) num.times { router.emit(@tag, Fluent::Engine.now, generate()) } end
# File lib/fluent/plugin/in_dummy.rb, line 81 def generate d = @dummy[@dummy_index] unless d @dummy_index = 0 d = @dummy[0] end @dummy_index += 1 if @auto_increment_key d = d.dup d[@auto_increment_key] = @increment_value @increment_value += 1 end d end
# File lib/fluent/plugin/in_dummy.rb, line 60 def run batch_num = (@rate / BIN_NUM).to_i residual_num = (@rate % BIN_NUM) while @running current_time = Time.now.to_i BIN_NUM.times do break unless (@running && Time.now.to_i <= current_time) wait(0.1) { emit(batch_num) } end emit(residual_num) # wait for next second while @running && Time.now.to_i <= current_time sleep 0.01 end end end
# File lib/fluent/plugin/in_dummy.rb, line 55 def shutdown @running = false @thread.join end
Generated with the Darkfish Rdoc Generator 2.