labels

package

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

Details

Append labels to each entity's properties.labels map.

processors:
  - name: labels
    config:
      labels:
        team: data-platform
        source: meteor

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

The processor reads the existing labels map from entity.properties.labels (or creates one if absent).
Each key from the config is merged into that map. Existing keys with the same name are overwritten.
The updated labels map is written back to entity.properties.labels.
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 {
	Labels map[string]string `mapstructure:"labels" 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