Skip to content
This repository has been archived by the owner on May 17, 2019. It is now read-only.

Issue #97 Improvements to in_forward documentation #104

Merged
merged 1 commit into from
May 4, 2014
Merged

Issue #97 Improvements to in_forward documentation #104

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
9 changes: 7 additions & 2 deletions docs/in_forward.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,11 @@ INCLUDE: _log_level_params

### Protocol

This plugin uses [MessagePack](http://msgpack.org/) for the internal protocol. MessagePack is a binary-based data serialization / deserialization library. `in_forward` accepts MessagePack data streams with the following structure.
This plugin accepts both JSON or [MessagePack](http://msgpack.org/) messages and automatically detects which is used. Internally, Fluent uses MessagePack as it is more efficient than JSON.

The time value is a platform specific integer and is based the out of Ruby's `Time.now.to_i` function. On Linux, BSD and MAC systems, this is the number of seconds since 1970.

Multiple messages may be sent in the same connection.

:::text
stream:
Expand All @@ -49,4 +53,5 @@ This plugin uses [MessagePack](http://msgpack.org/) for the internal protocol. M
[tag, [[time,record], [time,record], ...]]

example:
["myapp.access", [1308466941, {"a"=>1}], [1308466942, {"b"=>2}]]
["myapp.access", 1308466941, {"a":1}]["myapp.messages", 1308466942, {"b":2}]
["myapp.access", [[1308466941, {"a":1}], [1308466942, {"b":2}]]]