Sha256: 5fafc2778dc183775f7f4e515280d6703d4e43f6076985ca42353a24c17ee015

Contents?: true

Size: 780 Bytes

Versions: 125

Compression:

Stored size: 780 Bytes

Contents

<source>
  @type sample
  @label @exec
  tag exec_input
  rate 10
  auto_increment_key num
  sample {"data":"mydata"}
</source>

<label @exec>
  <match exec_input>
    @type exec_filter
    @label @stdout
    tag result
    command ruby -e 'STDOUT.sync = true; proc = ->(){line = STDIN.readline.chomp; puts line + "\t" + Process.pid.to_s}; 1000.times{ proc.call }'
    num_children 3
    child_respawn -1
    <inject>
      time_key time
      time_type float
    </inject>
    <format>
      @type tsv
      keys data, num, time
    </format>
    <parse>
      @type tsv
      keys data, num, time, pid
    </parse>
    <extract>
      time_key time
      time_type float
    </extract>
  </match>
</label>

<label @stdout>
  <match result>
    @type stdout
  </match>
</label>

Version data entries

125 entries across 125 versions & 7 rubygems

Version Path
fluentd-1.11.3-x64-mingw32 example/out_exec_filter.conf
fluentd-1.11.3 example/out_exec_filter.conf
fluentd-1.11.2-x64-mingw32 example/out_exec_filter.conf
fluentd-1.11.2-x86-mingw32 example/out_exec_filter.conf
fluentd-1.11.2 example/out_exec_filter.conf