api:
  enabled: true
  address: "127.0.0.1:{{ vector_api_port }}"

sources:
  docker_logs_in:
    type: docker_logs
    exclude_containers:
      - cadvisor
      - fluentbit
  vector_metrics_in:
    type: internal_metrics
    scrape_interval_secs: 30

transforms:
  docker_logs_remap:
    inputs:
      - docker_logs_in
    type: remap
    drop_on_abort: true
    source: |-
      msg, err = parse_json(.message)
      if err != null {
        abort
      }

      . = merge!(., msg)

      .hostname = "{{ ansible_fqdn }}"

      del(.message)
      del(.source_type)
      del(.host)
      del(.label)
      del(.ts)
      del(.stream)
      del(.system)
  docker_logs_agw_envoy:
    inputs:
      - docker_logs_remap
    type: filter
    condition: .service == "agw-envoy"
  docker_logs_agw_auth:
    inputs:
      - docker_logs_remap
    type: filter
    condition: .service == "agw-auth"

sinks:
  metrics_out:
    type: prometheus_exporter
    inputs:
      - vector_metrics_in
    address: "{{ private_ip }}:{{ vector_metrics_port }}"
  s3_out:
    type: aws_s3
    inputs:
      - docker_logs_agw_auth
      - docker_logs_agw_envoy
    encoding:
      codec: json
    buffer:
      type: disk
      max_size: 268435488 # ~256MB, the minimum allowed by the sink
    endpoint: "{{ vector_logging_s3_endpoint }}"
    auth:
      access_key_id: "<redacted>"
      secret_access_key: "<redacted>"
    bucket: "{{ vector_logging_s3_bucket }}"
    key_prefix: '{{ vector_logging_s3_key_prefix }}/{{ "{{ service }}" }}/'
    region: "{{ region }}"
    framing:
      method: newline_delimited