module Fluent::PluginNamedPipe