enrich

package

v0.13.0 Latest Latest Go to latest Published: Apr 19, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Append custom key-value pairs to each entity's properties map.

processors:
  - name: enrich
    config:
      attributes:
        team: data-platform
        environment: production

Key	Type	Required	Description
`attributes`	`map[string]string`	Yes	Key-value pairs to merge into `entity.properties`.

Each key in attributes is set directly in the entity's properties map. For example, team: data-platform results in entity.properties.team = "data-platform".
If a key already exists in properties, the value from the config overwrites it.
Only string values are written; non-string values in the config are ignored.
Edges attached to the record are passed through unchanged.

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

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Attributes map[string]any `mapstructure:"attributes" validate:"required"`
}

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

Processor work in a list of data

func New(logger log.Logger) *Processor

New create a new processor

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

Process processes the data

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

Process processes the data