decoupleafterbatchconverter

README

DecoupleAfterBatch Converter

The DecoupleAfterBatch converter automatically modifies the collector's configuration for the Lambda distribution. Its purpose is to ensure that a decouple processor is always present after a batch processor in a pipeline, in order to prevent potential data loss due to the Lambda environment being frozen.

Behavior

The converter scans the collector's configuration and makes the following adjustments:

1. If a pipeline contains a batch processor with no decouple processor defined after it, the converter will automatically add a decouple processor to the end of the pipeline.

2. If a pipeline contains a batch processor with a decouple processor already defined after it or there is no batch processor defined, the converter will not make any changes to the pipeline configuration.

Documentation

Overview

The decoupleafterbatchconverter implements the Converter for mutating Collector configurations to ensure the decouple processor is placed after the batch processor. This is logically implemented by appending the decouple processor to the end of processor chains where a batch processor is found unless another decouple processor was seen.

Index

• func New() confmap.Converter

Functions

func New

func New() confmap.Converter

New returns a confmap.Converter that ensures the decoupleprocessor is placed first in the pipeline.