Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
MessagePack-RPC input plugin for Fluentd data collector
Ruby
Branch: master

Fetching latest commit…

Cannot retrieve the latest commit at this time

Failed to load latest commit information.
lib/fluent/plugin
test/plugin
.gitignore
AUTHORS
ChangeLog
Gemfile
README.rst
Rakefile
VERSION
fluent-plugin-msgpack-rpc.gemspec

README.rst

About This Plugin

This plugin is an input plugin for Fluentd (http://fluentd.org/). All applications using MessagePack-RPC client can send events to Fluent by using this plugin.

How to Configure

<source>
  type msgpack_rpc
  port 9000
  bind 0.0.0.0
</source>

'bind' is an optional parameter.

Interface of the Server

The server has following interface:

def log(tag, time, record)
def logs(tag, entries)

'time' is a time when the event occurred. 'record' is a Hash having information of the event. 'entries' argument is an array of lists having [time, record]. When passing 0 to 'time', the server automatically use the current time as 'time'. See also a sample client code below.

Sample Client Code

require 'msgpack/rpc'
cli = MessagePack::RPC::Client.new('127.0.0.1', 9000)
cli.call(:log, 'debug.tag', 0, { 'key' => 'value' })
cli.call(:logs, 'debug.tag', [[0, {'key' => 'value'}], [Time.now.to_i, {'red' => 'bull'}]])
Something went wrong with that request. Please try again.