metadata

Documentation

Index

• type MetadataOperator
  • func (p *MetadataOperator) Process(ctx context.Context, entry *entry.Entry) error
  • func (p *MetadataOperator) Transform(entry *entry.Entry) (*entry.Entry, error)
• type MetadataOperatorConfig
  • func NewMetadataOperatorConfig(operatorID string) *MetadataOperatorConfig
  • func (c MetadataOperatorConfig) Build(context operator.BuildContext) (operator.Operator, error)

Types

type MetadataOperator

type MetadataOperator struct {
	helper.TransformerOperator
	helper.Labeler
	helper.Identifier
}

MetadataOperator is an operator that can add metadata to incoming entries

func (*MetadataOperator) Process

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

Process will process an incoming entry using the metadata transform.

func (*MetadataOperator) Transform

func (p *MetadataOperator) Transform(entry *entry.Entry) (*entry.Entry, error)

Transform will transform an entry using the labeler and tagger.

type MetadataOperatorConfig

type MetadataOperatorConfig struct {
	helper.TransformerConfig `yaml:",inline"`
	helper.LabelerConfig     `yaml:",inline"`
	helper.IdentifierConfig  `yaml:",inline"`
}

MetadataOperatorConfig is the configuration of a metadata operator

func NewMetadataOperatorConfig

func NewMetadataOperatorConfig(operatorID string) *MetadataOperatorConfig

NewMetadataOperatorConfig creates a new metadata config with default values

func (MetadataOperatorConfig) Build

func (c MetadataOperatorConfig) Build(context operator.BuildContext) (operator.Operator, error)

Build will build a metadata operator from the supplied configuration