Contents

<source>
  @type forward
  port 24224
</source>

<match w.**>
  @type records_merger
  tag result
  merge_timing before
  main_tag w.main
  sub_tag1 w.sub
  condition sub1["word"] == "hello"
  <record>
    main  ${main["word"]}
    sub   ${sub1["word"]}
  </record>
</match>

<match q.**>
  @type records_merger
  tag result
  merge_timing before
  main_tag q.main
  sub_tag1 q.sub1
  condition sub1["state"] == false
  <record>
    main  ${main["word"]}
    sub   ${sub1["word"]}
  </record>
</match>

<match x.**>
  @type records_merger
  tag result
  merge_timing before
  main_tag x.main
  sub_tag1 x.sub1
  condition sub1 != nil
  emit_first_main true
  <record>
    main  ${main["word"]}
    sub   ${sub1["word"]}
  </record>
</match>

<match result>
  @type stdout
</match>

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-records-merger-0.1.7	example/fluent.conf