fluent-plugin-unix-client

Fluentd input plugin to receive data from UNIX domain socket.
This is a client version of the default unix plugin.

$ gem install fluent-plugin-unix-client

Add following line to your Gemfile:

gem "fluent-plugin-unix-client"

And then execute:

$ bundle

Tag of output events.

The path to Unix Domain Socket.

Note: This is a client side application, so you need to set the path which is opened by another server side application.

This plugin use Fluentd parser plugin as a helper.
See Config: Parse Section.

The payload is read up to this character.

Default value: "\n" (newline).

When recieved JSON data splitted by the delimiter is not completed, like '[{...},', trim '[', ']' and ',' characters to format.

Please see Sample below for details.

Default value: false.

Config:

<source>
  @type unix_client
  tag debug.unix_client
  path /tmp/unix.sock
  <parse>
    @type json
  </parse>
  delimiter "\n"
</source>

<match debug.**>
  @type stdout
</match>

Assumed Data:

• ndjson

{"key":0}\n
{"key":0}\n
...

• JSON list

[{"key":0}, {"key":0}, ...]\n
[{"key":0}, {"key":0}, ...]\n
...

Config:

<source>
  @type unix_client
  tag debug.unix_client
  path /tmp/unix.sock
  <parse>
    @type json
  </parse>
  delimiter "\n"
  format_json true
</source>

<match debug.**>
  @type stdout
</match>

Assumed Data:

[{"key":0},\n
{"key":0},\n
...
{"key":0}]\n
...

• This recieves data from UNIX domain socket which is opened by another application.
  • If you need other applications to send data to the socket you opened, you can use the default unix plugin.
• If this can't connect to the socket, this trys to reconnect later.

• Copyright(c) 2021- daipom
• License
  • Apache License, Version 2.0