module BinlogReaderCommand
module BinlogReaderCommand::Formattable
module Fluent
module Fluent::ChunkMessagePackEventStreamer
module Fluent::Clock
module Fluent::Compat
module Fluent::Compat::AddKeyToChunkMixin
module Fluent::Compat::AddTimeSliceKeyToChunkMixin
module Fluent::Compat::BufferedChunkMixin
module Fluent::Compat::BufferedEventStreamMixin
module Fluent::Compat::CallSuperMixin
module Fluent::Compat::ChunkSizeCompatMixin
module Fluent::Compat::CompatOutputUtils
module Fluent::Compat::DetachMultiProcessMixin
module Fluent::Compat::DetachProcessMixin
module Fluent::Compat::ExecUtil
module Fluent::Compat::FileUtil
module Fluent::Compat::FormatterUtils
module Fluent::Compat::FormatterUtils::InjectMixin
module Fluent::Compat::HandleTagAndTimeMixin
module Fluent::Compat::HandleTagNameMixin
module Fluent::Compat::ParserUtils
module Fluent::Compat::PropagateDefault
module Fluent::Compat::PropagateDefault::ClassMethods
module Fluent::Compat::RecordFilterMixin
module Fluent::Compat::SetTagKeyMixin
module Fluent::Compat::SetTimeKeyMixin
module Fluent::Compat::SocketUtil
module Fluent::Compat::StringUtil
module Fluent::Compat::StructuredFormatMixin
module Fluent::Compat::TextFormatter
module Fluent::Compat::TextParser::TypeConverterCompatParameters
module Fluent::Compat::TimeSliceChunkMixin
module Fluent::Compat::TypeConverter
module Fluent::Config
module Fluent::Config::BasicParser::ClassMethods
module Fluent::Config::DSL
module Fluent::Config::DSL::Parser
module Fluent::Config::SectionGenerator
module Fluent::Configurable
module Fluent::Configurable::ClassMethods
module Fluent::Counter
module Fluent::FileWrapper
module Fluent::Log::TTYColor
module Fluent::MessagePackFactory
module Fluent::MessagePackFactory::Mixin
module Fluent::Plugin
module Fluent::Plugin::Buffer::Chunk::Decompressable
module Fluent::Plugin::Compressable
module Fluent::Plugin::FeatureAvailabilityChecker
module Fluent::Plugin::FileOutput::SymlinkBufferMixin
module Fluent::Plugin::OwnedByMixin
module Fluent::PluginHelper
module Fluent::PluginHelper::CertOption
module Fluent::PluginHelper::ChildProcess
module Fluent::PluginHelper::CompatParameters
module Fluent::PluginHelper::Counter
module Fluent::PluginHelper::EventEmitter
module Fluent::PluginHelper::EventLoop
module Fluent::PluginHelper::Extract
module Fluent::PluginHelper::Extract::ExtractParams
module Fluent::PluginHelper::Formatter
module Fluent::PluginHelper::Formatter::FormatterParams
module Fluent::PluginHelper::HttpServer
module Fluent::PluginHelper::HttpServer::Compat
module Fluent::PluginHelper::HttpServer::Methods
module Fluent::PluginHelper::Inject
module Fluent::PluginHelper::Inject::InjectParams
module Fluent::PluginHelper::Mixin
module Fluent::PluginHelper::Parser
module Fluent::PluginHelper::Parser::ParserParams
module Fluent::PluginHelper::RecordAccessor
module Fluent::PluginHelper::RetryState
module Fluent::PluginHelper::Server
module Fluent::PluginHelper::Server::EventHandler
module Fluent::PluginHelper::Server::ServerTransportParams
module Fluent::PluginHelper::Socket
module Fluent::PluginHelper::Socket::WrappedSocket
module Fluent::PluginHelper::SocketOption
module Fluent::PluginHelper::Storage
module Fluent::PluginHelper::Storage::StorageParams
module Fluent::PluginHelper::Thread
module Fluent::PluginHelper::Timer
module Fluent::PluginId
module Fluent::PluginLoggerMixin
module Fluent::RPC
module Fluent::ServerModule
module Fluent::SystemConfig::Mixin
module Fluent::Test
module Fluent::Test::Driver
module Fluent::Test::Driver::EventFeeder
module Fluent::Test::Helpers
module Fluent::Test::InputTestDriver::EmitStreamWrapper
module Fluent::Test::StartupShutdown
module Fluent::TimeMixin
module Fluent::TimeMixin::Formatter
module Fluent::TimeMixin::Parser
module Fluent::TimeMixin::TimeParameters
module Fluent::UniqueId
module Fluent::UniqueId::Mixin
module Fluent::WindowsFileExtension
module Fluent::WorkerModule
class BinlogReaderCommand::Base
class BinlogReaderCommand::Cat
class BinlogReaderCommand::Formats
class BinlogReaderCommand::Head
class Fluent::Agent
class Fluent::AllMatchPattern
class Fluent::ArrayEventStream
class Fluent::CaGenerate
class Fluent::Compat::BufferedOutput
class Fluent::Compat::CopyOutputChain
class Fluent::Compat::ExecUtil::Formatter
class Fluent::Compat::ExecUtil::JSONFormatter
class Fluent::Compat::ExecUtil::JSONParser
class Fluent::Compat::ExecUtil::MessagePackFormatter
class Fluent::Compat::ExecUtil::MessagePackParser
class Fluent::Compat::ExecUtil::Parser
class Fluent::Compat::ExecUtil::TSVFormatter
class Fluent::Compat::ExecUtil::TSVParser
class Fluent::Compat::ExecUtil::TextParserWrapperParser
class Fluent::Compat::Filter
class Fluent::Compat::Formatter
class Fluent::Compat::Input
class Fluent::Compat::MultiOutput
class Fluent::Compat::NullOutputChain
class Fluent::Compat::ObjectBufferedOutput
class Fluent::Compat::Output
class Fluent::Compat::OutputChain
class Fluent::Compat::Parser
class Fluent::Compat::SocketUtil::BaseInput
class Fluent::Compat::SocketUtil::TcpHandler
class Fluent::Compat::SocketUtil::UdpHandler
class Fluent::Compat::TextFormatter::CsvFormatter
class Fluent::Compat::TextFormatter::HashFormatter
class Fluent::Compat::TextFormatter::JSONFormatter
class Fluent::Compat::TextFormatter::LabeledTSVFormatter
class Fluent::Compat::TextFormatter::MessagePackFormatter
class Fluent::Compat::TextFormatter::OutFileFormatter
class Fluent::Compat::TextFormatter::ProcWrappedFormatter
class Fluent::Compat::TextFormatter::SingleValueFormatter
class Fluent::Compat::TextFormatter::StdoutFormatter
class Fluent::Compat::TextParser
class Fluent::Compat::TextParser::ApacheParser
class Fluent::Compat::TextParser::CSVParser
class Fluent::Compat::TextParser::JSONParser
class Fluent::Compat::TextParser::LabeledTSVParser
class Fluent::Compat::TextParser::MultilineParser
class Fluent::Compat::TextParser::NoneParser
class Fluent::Compat::TextParser::RegexpParser
class Fluent::Compat::TextParser::SyslogParser
class Fluent::Compat::TextParser::TSVParser
class Fluent::Compat::TextParser::TimeParser
class Fluent::Compat::TextParser::ValuesParser
class Fluent::Compat::TimeSlicedOutput
class Fluent::CompressedMessagePackEventStream
class Fluent::Config::BasicParser
class Fluent::Config::ConfigureProxy
class Fluent::Config::DSL::Element
class Fluent::Config::DSL::Proxy
class Fluent::Config::Element
class Fluent::Config::LiteralParser
class Fluent::Config::Parser
class Fluent::Config::Section
class Fluent::Config::V1Parser
class Fluent::ConfigError
class Fluent::ConfigParseError
class Fluent::Counter::ArrayValidator
class Fluent::Counter::BaseError
class Fluent::Counter::BaseSocket
class Fluent::Counter::CleanupThread
class Fluent::Counter::Client
class Fluent::Counter::Connection
class Fluent::Counter::Future
class Fluent::Counter::Future::Result
class Fluent::Counter::Handler
class Fluent::Counter::HashValidator
class Fluent::Counter::InternalServerError
class Fluent::Counter::InvalidParams
class Fluent::Counter::InvalidRequest
class Fluent::Counter::MethodNotFound
class Fluent::Counter::MutexHash
class Fluent::Counter::ParseError
class Fluent::Counter::Server
class Fluent::Counter::Server::Response
class Fluent::Counter::Store
class Fluent::Counter::Store::DummyParent
class Fluent::Counter::UnknownKey
class Fluent::Counter::Validator
class Fluent::EngineClass
class Fluent::EventRouter
class Fluent::EventRouter::MatchCache
class Fluent::EventRouter::Pipeline
class Fluent::EventRouter::Pipeline::FilterOptimizer
class Fluent::EventRouter::Rule
class Fluent::EventStream
class Fluent::EventTime
class Fluent::GlobMatchPattern
class Fluent::InvalidRootDirectory
class Fluent::Label
class Fluent::Log
class Fluent::LogDeviceIO
class Fluent::MatchPattern
class Fluent::MessagePackEventStream
class Fluent::MultiEventStream
class Fluent::NoMatchMatch
class Fluent::NumericTimeFormatter
class Fluent::NumericTimeParser
class Fluent::ObsoletedParameterError
class Fluent::OneEventStream
class Fluent::OrMatchPattern
class Fluent::Plugin::Apache2Parser
class Fluent::Plugin::ApacheErrorParser
class Fluent::Plugin::ApacheParser
class Fluent::Plugin::BareOutput
class Fluent::Plugin::Base
class Fluent::Plugin::Buffer
class Fluent::Plugin::Buffer::BufferChunkOverflowError
class Fluent::Plugin::Buffer::BufferError
class Fluent::Plugin::Buffer::BufferOverflowError
class Fluent::Plugin::Buffer::Chunk
class Fluent::Plugin::Buffer::FileChunk
class Fluent::Plugin::Buffer::FileChunk::FileChunkError
class Fluent::Plugin::Buffer::MemoryChunk
class Fluent::Plugin::Buffer::ShouldRetry
class Fluent::Plugin::CSVParser
class Fluent::Plugin::CopyOutput
class Fluent::Plugin::CsvFormatter
class Fluent::Plugin::DebugAgentInput
class Fluent::Plugin::DummyInput
class Fluent::Plugin::ExecFilterOutput
class Fluent::Plugin::ExecInput
class Fluent::Plugin::ExecOutput
class Fluent::Plugin::FileBuffer
class Fluent::Plugin::FileOutput
class Fluent::Plugin::Filter
class Fluent::Plugin::Formatter
class Fluent::Plugin::ForwardInput
class Fluent::Plugin::ForwardOutput
class Fluent::Plugin::ForwardOutput::ConnectionClosedError
class Fluent::Plugin::ForwardOutput::Error
class Fluent::Plugin::ForwardOutput::FailureDetector
class Fluent::Plugin::ForwardOutput::NoNodesAvailable
class Fluent::Plugin::ForwardOutput::Node
class Fluent::Plugin::ForwardOutput::Node::SocketCache
class Fluent::Plugin::ForwardOutput::NoneHeartbeatNode
class Fluent::Plugin::GCStatInput
class Fluent::Plugin::GrepFilter
class Fluent::Plugin::HashFormatter
class Fluent::Plugin::HttpInput
class Fluent::Plugin::HttpInput::Handler
class Fluent::Plugin::HttpInput::KeepaliveManager
class Fluent::Plugin::InHttpParser
class Fluent::Plugin::Input
class Fluent::Plugin::JSONFormatter
class Fluent::Plugin::JSONParser
class Fluent::Plugin::LabeledTSVFormatter
class Fluent::Plugin::LabeledTSVParser
class Fluent::Plugin::LocalStorage
class Fluent::Plugin::MemoryBuffer
class Fluent::Plugin::MessagePackFormatter
class Fluent::Plugin::MessagePackParser
class Fluent::Plugin::MonitorAgentInput
class Fluent::Plugin::MonitorAgentInput::APIHandler
class Fluent::Plugin::MonitorAgentInput::NotFoundJson
class Fluent::Plugin::MultiOutput
class Fluent::Plugin::MultilineParser
class Fluent::Plugin::NginxParser
class Fluent::Plugin::NoneParser
class Fluent::Plugin::NullOutput
class Fluent::Plugin::ObjectSpaceInput
class Fluent::Plugin::ObjectSpaceInput::Counter
class Fluent::Plugin::OutFileFormatter
class Fluent::Plugin::Output
class Fluent::Plugin::Output::PlaceholderValidator
class Fluent::Plugin::Parser
class Fluent::Plugin::Parser::ParserError
class Fluent::Plugin::ParserFilter
class Fluent::Plugin::ProcWrappedFormatter
class Fluent::Plugin::RecordTransformerFilter
class Fluent::Plugin::RecordTransformerFilter::PlaceholderExpander
class Fluent::Plugin::RecordTransformerFilter::RubyPlaceholderExpander
class Fluent::Plugin::RecordTransformerFilter::RubyPlaceholderExpander::CleanroomExpander
class Fluent::Plugin::RegexpParser
class Fluent::Plugin::RelabelOutput
class Fluent::Plugin::RoundRobinOutput
class Fluent::Plugin::SecondaryFileOutput
class Fluent::Plugin::SingleValueFormatter
class Fluent::Plugin::StdoutFilter
class Fluent::Plugin::StdoutFormatter
class Fluent::Plugin::StdoutOutput
class Fluent::Plugin::Storage
class Fluent::Plugin::SyslogInput
class Fluent::Plugin::SyslogParser
class Fluent::Plugin::TSVFormatter
class Fluent::Plugin::TSVParser
class Fluent::Plugin::TailInput
class Fluent::Plugin::TailInput::FilePositionEntry
class Fluent::Plugin::TailInput::MemoryPositionEntry
class Fluent::Plugin::TailInput::PositionFile
class Fluent::Plugin::TailInput::TailWatcher
class Fluent::Plugin::TailInput::TailWatcher::FIFO
class Fluent::Plugin::TailInput::TailWatcher::IOHandler
class Fluent::Plugin::TailInput::TailWatcher::LineBufferTimerFlusher
class Fluent::Plugin::TailInput::TailWatcher::NullIOHandler
class Fluent::Plugin::TailInput::TailWatcher::RotateHandler
class Fluent::Plugin::TailInput::TailWatcher::StatWatcher
class Fluent::Plugin::TailInput::TailWatcher::TimerTrigger
class Fluent::Plugin::TailInput::WatcherSetupError
class Fluent::Plugin::TcpInput
class Fluent::Plugin::UdpInput
class Fluent::PluginHelper::EventLoop::DefaultWatcher
class Fluent::PluginHelper::HttpServer::App
class Fluent::PluginHelper::HttpServer::Compat::Server
class Fluent::PluginHelper::HttpServer::Compat::WebrickHandler
class Fluent::PluginHelper::HttpServer::Request
class Fluent::PluginHelper::HttpServer::Router
class Fluent::PluginHelper::HttpServer::Router::NotFoundApp
class Fluent::PluginHelper::HttpServer::Server
class Fluent::PluginHelper::RecordAccessor::Accessor
class Fluent::PluginHelper::RetryState::ExponentialBackOffRetry
class Fluent::PluginHelper::RetryState::PeriodicRetry
class Fluent::PluginHelper::RetryState::RetryStateMachine
class Fluent::PluginHelper::Server::CallbackSocket
class Fluent::PluginHelper::Server::EventHandler::TCPServer
class Fluent::PluginHelper::Server::EventHandler::TLSServer
class Fluent::PluginHelper::Server::EventHandler::UDPServer
class Fluent::PluginHelper::Server::TCPCallbackSocket
class Fluent::PluginHelper::Server::TLSCallbackSocket
class Fluent::PluginHelper::Server::UDPCallbackSocket
class Fluent::PluginHelper::Socket::WrappedSocket::TCP
class Fluent::PluginHelper::Socket::WrappedSocket::TLS
class Fluent::PluginHelper::Socket::WrappedSocket::UDP
class Fluent::PluginHelper::Storage::PersistentWrapper
class Fluent::PluginHelper::Storage::SynchronizeWrapper
class Fluent::PluginHelper::Timer::TimerWatcher
class Fluent::PluginLogger
class Fluent::RPC::Server
class Fluent::Registry
class Fluent::RootAgent
class Fluent::RootAgent::RootAgentProxyWithoutErrorCollector
class Fluent::StreamInput
class Fluent::StreamInput::Handler
class Fluent::StreamOutput
class Fluent::StreamOutput::ReformatWriter
class Fluent::Supervisor
class Fluent::Supervisor::LoggerInitializer
class Fluent::SystemConfig
class Fluent::TcpOutput
class Fluent::Test::BufferedOutputTestDriver
class Fluent::Test::Driver::Base
class Fluent::Test::Driver::BaseOwned
class Fluent::Test::Driver::BaseOwner
class Fluent::Test::Driver::Filter
class Fluent::Test::Driver::Formatter
class Fluent::Test::Driver::Input
class Fluent::Test::Driver::MultiOutput
class Fluent::Test::Driver::Output
class Fluent::Test::Driver::OwnerDummy
class Fluent::Test::Driver::Parser
class Fluent::Test::Driver::TestEventRouter
class Fluent::Test::Driver::TestTimedOut
class Fluent::Test::DummyLogDevice
class Fluent::Test::FilterTestDriver
class Fluent::Test::FormatterTestDriver
class Fluent::Test::InputTestDriver
class Fluent::Test::OutputTestDriver
class Fluent::Test::ParserTestDriver
class Fluent::Test::TestDriver
class Fluent::Test::TestLogger
class Fluent::Test::TestOutputChain
class Fluent::Test::TimeSlicedOutputTestDriver
class Fluent::TimeFormatter
class Fluent::TimeParser
class Fluent::TimeParser::TimeParseError
class Fluent::Timezone
class Fluent::UnixInput
class Fluent::UnixOutput
class Fluent::UnrecoverableError
class Fluent::WindowsFile
class FluentBinlogReader
class FluentPluginConfigFormatter
class FluentPluginGenerator
class FluentPluginGenerator::ApacheLicense
class FluentPluginGenerator::NoLicense
class FluentdService
class Writer
class Writer::TimerThread
fluentd
1.6.0
# process
def process(tag, es) router.emit_stream(tag, es) end