Class: Fluent::Test::Driver::Input

Inherits:

Object
Base
BaseOwner
Fluent::Test::Driver::Input

Defined in:: lib/fluent/test/driver/input.rb

Constant Summary

Constants inherited from Base

Base::DEFAULT_TIMEOUT

Instance Attribute Summary

Attributes inherited from Base

#instance, #logs

Instance Method Summary collapse

#initialize(klass, opts: {}, &block) ⇒ Input constructor

A new instance of Input.

Methods inherited from BaseOwner

#configure, #emit_count, #emit_error_event, #emit_event_stream, #error_events, #event_streams, #events, #record_count, #run

Methods inherited from Base

#break_if, #broken?, #configure, #end_if, #instance_hook_after_started, #instance_hook_before_stopped, #instance_shutdown, #instance_start, #run, #run_actual, #stop?

Constructor Details

#initialize(klass, opts: {}, &block) ⇒ `Input`

Returns a new instance of Input.

Raises:

(ArgumentError)

# File 'lib/fluent/test/driver/input.rb', line 24

def initialize(klass, opts: {}, &block)
  super
  raise ArgumentError, "plugin is not an instance of Fluent::Plugin::Input" unless @instance.is_a? Fluent::Plugin::Input
end