You are looking at preliminary documentation for a future release.
Not what you want? See the
current release documentation.
fluentedit
This codec handles fluentd’s msgpack schema.
For example, you can receive logs from fluent-logger-ruby with:
input {
tcp {
codec => fluent
port => 4000
}
}And from your ruby code in your own application:
logger = Fluent::Logger::FluentLogger.new(nil, :host => "example.log", :port => 4000)
logger.post("some_tag", { "your" => "data", "here" => "yay!" })Notes:
- the fluent uses a second-precision time for events, so you will never see subsecond precision on events processed by this codec.