transform

Documentation

Index

• func NewBuilder(b func(Config) (Transform, error)) processor.Builder
• type Config
• type Transform
  • func (t Transform) Execute(_ context.Context, record record.Record) (record.Record, error)
  • func (t Transform) Type() processor.Type

Functions

func NewBuilder

func NewBuilder(b func(Config) (Transform, error)) processor.Builder

NewBuilder is a utility function for creating a processor.Builder for transforms.

Types

type Config

type Config map[string]string

Config holds configuration data for building a transform.

type Transform

type Transform func(record.Record) (record.Record, error)

Transform takes a record and if successful returns the transformed record, an error otherwise.

func (Transform) Execute

func (t Transform) Execute(_ context.Context, record record.Record) (record.Record, error)

func (Transform) Type

func (t Transform) Type() processor.Type