labels

README

labels

labels processor will append Asset's Labels with value from given config.

Usage

processors:
  - name: labels
    config:
      labels:
        foo: bar
        myLabel: myValue       

Inputs

Key	Value	Example	Description
labels	object	{"foo": "bar"}	Map of string	required

Contributing

Refer to the contribution guidelines for information on contributing to this module.

Documentation

Index

• type Config
• type Processor
  • func New(logger log.Logger) *Processor
  • func (p *Processor) Init(ctx context.Context, config plugins.Config) (err error)
  • func (p *Processor) Process(ctx context.Context, src models.Record) (dst models.Record, err error)

Types

type Config

type Config struct {
	Labels map[string]string `mapstructure:"labels" validate:"required"`
}

type Processor

type Processor struct {
	plugins.BasePlugin
	// contains filtered or unexported fields
}

Processor work in a list of data

func New

func New(logger log.Logger) *Processor

New create a new processor

func (*Processor) Init

func (p *Processor) Init(ctx context.Context, config plugins.Config) (err error)

Process processes the data

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, src models.Record) (dst models.Record, err error)

Process processes the data