http://noops.me/?p=1325

class SomeOutput < Fluent::Output

First, register the plugin. NAME is the name of this plugin

and identifies the plugin in the configuration file.

Fluent::Plugin.register_output('NAME', self)

This method is called before starting.

def configure(conf)
super
...
end

This method is called when starting.

def start
super
...
end

This method is called when shutting down.

def shutdown
super
...
end

This method is called when an event reaches Fluentd.

'es' is a Fluent::EventStream object that includes multiple events.

You can use 'es.each {|time,record| ... }' to retrieve events.

'chain' is an object that manages transactions. Call 'chain.next' at

appropriate points and rollback if it raises an exception.

def emit(tag, es, chain)
chain.next
es.each {|time,record|
$stderr.puts "OK!"
}
end
end