tests: integration: add Manticore output coverage

Signed-off-by: Stas <tomat1979@gmail.com>

Author: tomatolog

tests/integration/scenarios/out_manticore/config/out_manticore_permanent.yaml

@@ -0,0 +1,19 @@
+service:
+  flush: 0.2
+  log_level: info
+  http_server: on
+  http_port: ${FLUENT_BIT_HTTP_MONITORING_PORT}
+
+pipeline:
+  inputs:
+    - name: dummy
+      tag: manticore_permanent
+      dummy: '{"id":44,"message":"permanent-item"}'
+      samples: 1
+
+  outputs:
+    - name: manticore
+      match: '*'
+      host: 127.0.0.1
+      port: ${MANTICORE_PORT}
+      table: wire_logs

tests/integration/scenarios/out_manticore/config/out_manticore_recovery.yaml

@@ -0,0 +1,26 @@
+service:
+  flush: 0.2
+  grace: 3
+  log_level: info
+  http_server: on
+  http_port: ${FLUENT_BIT_HTTP_MONITORING_PORT}
+  parsers_file: ${MANTICORE_PARSERS_FILE}
+
+pipeline:
+  inputs:
+    - name: tail
+      tag: manticore_recovery
+      path: ${MANTICORE_INPUT_PATH}
+      read_from_head: true
+      exit_on_eof: ${MANTICORE_EXIT_ON_EOF}
+      parser: recovery_json
+
+  outputs:
+    - name: manticore
+      match: '*'
+      host: 127.0.0.1
+      port: ${MANTICORE_PORT}
+      table: ${MANTICORE_TABLE}
+      workers: 1
+      single_chunk: true
+      spool_path: ${MANTICORE_SPOOL_PATH}

tests/integration/scenarios/out_manticore/config/out_manticore_retry.yaml

@@ -0,0 +1,20 @@
+service:
+  flush: 0.2
+  log_level: info
+  http_server: on
+  http_port: ${FLUENT_BIT_HTTP_MONITORING_PORT}
+
+pipeline:
+  inputs:
+    - name: dummy
+      tag: manticore_retry
+      dummy: '{"id":"43","message":"retry-item"}'
+      samples: 1
+
+  outputs:
+    - name: manticore
+      match: '*'
+      host: 127.0.0.1
+      port: ${MANTICORE_PORT}
+      table: wire_logs
+      action: create

tests/integration/scenarios/out_manticore/config/out_manticore_session.yaml

@@ -0,0 +1,28 @@
+service:
+  flush: 0.2
+  grace: 3
+  log_level: info
+  http_server: on
+  http_port: ${FLUENT_BIT_HTTP_MONITORING_PORT}
+  parsers_file: ${MANTICORE_PARSERS_FILE}
+
+pipeline:
+  inputs:
+    - name: tail
+      tag: manticore_session
+      path: ${MANTICORE_INPUT_PATH}
+      refresh_interval: 1
+      read_from_head: true
+      exit_on_eof: ${MANTICORE_EXIT_ON_EOF}
+      parser: session_json
+
+  outputs:
+    - name: manticore
+      match: '*'
+      host: 127.0.0.1
+      port: ${MANTICORE_PORT}
+      table: session_logs
+      workers: 1
+      single_chunk: true
+      spool_path: ${MANTICORE_SPOOL_PATH}
+      stream_chunk_size: 64K

tests/integration/scenarios/out_manticore/config/out_manticore_spool.yaml

@@ -0,0 +1,26 @@
+service:
+  flush: 0.1
+  grace: 3
+  log_level: info
+  http_server: on
+  http_port: ${FLUENT_BIT_HTTP_MONITORING_PORT}
+  parsers_file: ${MANTICORE_PARSERS_FILE}
+
+pipeline:
+  inputs:
+    - name: tail
+      tag: manticore_spool
+      path: ${MANTICORE_INPUT_PATH}
+      read_from_head: true
+      exit_on_eof: ${MANTICORE_EXIT_ON_EOF}
+      parser: spool_json
+
+  outputs:
+    - name: manticore
+      match: '*'
+      host: 127.0.0.1
+      port: ${MANTICORE_PORT}
+      table: spool_logs
+      workers: 1
+      single_chunk: true
+      spool_path: ${MANTICORE_SPOOL_PATH}

tests/integration/scenarios/out_manticore/config/out_manticore_wire.yaml

@@ -0,0 +1,22 @@
+service:
+  flush: 0.2
+  log_level: info
+  http_server: on
+  http_port: ${FLUENT_BIT_HTTP_MONITORING_PORT}
+  parsers_file: ${MANTICORE_PARSERS_FILE}
+
+pipeline:
+  inputs:
+    - name: tail
+      tag: manticore_wire
+      path: ${MANTICORE_INPUT_PATH}
+      read_from_head: true
+      parser: manticore_json
+
+  outputs:
+    - name: manticore
+      match: '*'
+      host: 127.0.0.1
+      port: ${MANTICORE_PORT}
+      table: wire logs
+      stream_chunk_size: 128