flatten

Documentation

Index

• type FlattenOperator
  • func (p *FlattenOperator) Process(ctx context.Context, entry *entry.Entry) error
  • func (p *FlattenOperator) Transform(entry *entry.Entry) error
• type FlattenOperatorConfig
  • func NewFlattenOperatorConfig(operatorID string) *FlattenOperatorConfig
  • func (c FlattenOperatorConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Types

type FlattenOperator

type FlattenOperator struct {
	helper.TransformerOperator
	Field entry.RecordField
}

FlattenOperator flattens an object in the body field

func (*FlattenOperator) Process

func (p *FlattenOperator) Process(ctx context.Context, entry *entry.Entry) error

Process will process an entry with a flatten transformation.

func (*FlattenOperator) Transform

func (p *FlattenOperator) Transform(entry *entry.Entry) error

Transform will apply the flatten operation to an entry

type FlattenOperatorConfig

type FlattenOperatorConfig struct {
	helper.TransformerConfig `mapstructure:",squash" yaml:",inline"`
	Field                    entry.RecordField `mapstructure:"field" json:"field" yaml:"field"`
}

FlattenOperatorConfig is the configuration of a flatten operator

func NewFlattenOperatorConfig

func NewFlattenOperatorConfig(operatorID string) *FlattenOperatorConfig

NewFlattenOperatorConfig creates a new flatten operator config with default values

func (FlattenOperatorConfig) Build

func (c FlattenOperatorConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Build will build a Flatten operator from the supplied configuration