test/test_plugin_classes.rb in fluentd-0.12.0.pre.3 vs test/test_plugin_classes.rb in fluentd-0.12.0

@@ -1,40 +1,78 @@
 require_relative 'helper'
 
 module FluentTest
+  class FluentTestInput < ::Fluent::Input
+    ::Fluent::Plugin.register_input('test_in', self)
+
+    attr_reader :started
+
+    def start
+      @started = true
+    end
+
+    def shutdown
+      @started = false
+    end
+  end
+
   class FluentTestOutput < ::Fluent::Output
+    ::Fluent::Plugin.register_output('test_out', self)
+
     def initialize
       super
       @events = Hash.new { |h, k| h[k] = [] }
     end
 
     attr_reader :events
+    attr_reader :started
 
+    def start
+      @started = true
+    end
+
+    def shutdown
+      @started = false
+    end
+
     def emit(tag, es, chain)
       es.each { |time, record|
         @events[tag] << record
       }
     end
   end
 
   class FluentTestErrorOutput < ::Fluent::BufferedOutput
+    ::Fluent::Plugin.register_output('test_out_error', self)
+
     def format(tag, time, record)
       raise "emit error!"
     end
 
     def write(chunk)
       raise "chunk error!"
     end
   end
 
   class FluentTestFilter < ::Fluent::Filter
+    ::Fluent::Plugin.register_filter('test_filter', self)
+
     def initialize(field = '__test__')
       super()
       @num = 0
       @field = field
     end
 
     attr_reader :num
+    attr_reader :started
+
+    def start
+      @started = true
+    end
+
+    def shutdown
+      @started = false
+    end
 
     def filter(tag, time, record)
       record[@field] = @num
       @num += 1
       record