enrich

README

Enrich

Documentation

Index

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

Types

type Config

type Config struct {
	Attributes map[string]interface{} `mapstructure:"attributes" 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) error

Process processes the data

func (*Processor) Process

func (p *Processor) Process(_ context.Context, src models.Record) (models.Record, error)

Process processes the data