parameters:
  fluentd:
    agent:
      config:
        label:
          rabbitmq_notifications:
            input:
              tail_rabbitmq_info:
                tag: raw_notifications
                type: rabbitmq
                host: ${_param:openstack_message_queue_address}
                user: openstack
                pass: ${_param:rabbitmq_openstack_password}
                vhost: /openstack
                queue: ${_param:stacklight_notification_topic}.info
                routing_key: ${_param:stacklight_notification_topic}.info
                parser:
                  type: json
              tail_rabbitmq_warn:
                tag: raw_notifications
                type: rabbitmq
                host: ${_param:openstack_message_queue_address}
                user: openstack
                pass: ${_param:rabbitmq_openstack_password}
                vhost: /openstack
                queue: ${_param:stacklight_notification_topic}.warn
                routing_key: ${_param:stacklight_notification_topic}.warn
                parser:
                  type: json
              tail_rabbitmq_error:
                tag: raw_notifications
                type: rabbitmq
                host: ${_param:openstack_message_queue_address}
                user: openstack
                pass: ${_param:rabbitmq_openstack_password}
                vhost: /openstack
                queue: ${_param:stacklight_notification_topic}.error
                routing_key: ${_param:stacklight_notification_topic}.error
                parser:
                  type: json
            filter:
              parse_json:
                tag: raw_notifications
                type: parser
                key_name: oslo.message
                reserve_data: false
                hash_value_field: parsed
                parser:
                  type: json
              remove_context:
                tag: raw_notifications
                require:
                  - parse_json
                type: record_transformer
                enable_ruby: true
                remove_keys: _dummy_1
                record:
                  - name: _dummy_1
                    value: ${fluentd:dollar}{record['parsed'].delete_if { |k,_| k.include?('_context_') }; nil}
              pack_parsed_to_json:
                tag: raw_notifications
                require:
                  - remove_context
                type: record_transformer
                enable_ruby: true
                record:
                  - name: parsed
                    value: ${fluentd:dollar}{record["parsed"].to_json}
              unpack_on_top_level:
                tag: raw_notifications
                require:
                  - pack_parsed_to_json
                type: parser
                key_name: parsed
                reserve_data: false
                parser:
                  type: json
              detect_audit_notification:
                tag: raw_notifications
                require:
                  - unpack_on_top_level
                type: record_transformer
                enable_ruby: true
                record:
                  - name: notification_type
                    value: '${fluentd:dollar}{ record["payload"].key?("eventType") && record["payload"].key?("eventTime") ? "audit" : "notification" }'
            match:
              rewrite_message_tag:
                tag: raw_notifications
                type: rewrite_tag_filter
                rule:
                  - name: notification_type
                    regexp: 'audit'
                    result: audit
                  - name: notification_type
                    regexp: '/.+/'
                    result: notification
              forward_notification:
                tag: notification
                type: relabel
                label: notification_messages
              forward_audit:
                tag: audit
                type: relabel
                label: audit_messages