transform

README

transform

Contains interfaces and methods for transforming data as it moves from a source to a sink.

Each transform must use a select statement to read and write data to its channels and check if context was cancelled to prevent goroutine leaks (learn more about goroutine leaks here).

Information for each transform is available in the GoDoc.

Documentation

Index

• type Transformer
  • func New(ctx context.Context, cfg config.Config) (Transformer, error)

Types

type Transformer

type Transformer interface {
	Transform(context.Context, *sync.WaitGroup, *config.Channel, *config.Channel) error
}

func New

func New(ctx context.Context, cfg config.Config) (Transformer, error)

New returns a configured Transformer from a transform configuration.