transformation

Documentation

Index

• func NewAdapter(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ...) pkgadapter.Adapter
• func NewEnvConfig() pkgadapter.EnvConfigAccessor
• type Pipeline

Functions

func NewAdapter

func NewAdapter(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ceClient cloudevents.Client) pkgadapter.Adapter

func NewEnvConfig

func NewEnvConfig() pkgadapter.EnvConfigAccessor

NewEnvConfig satisfies pkgadapter.EnvConfigConstructor.

Types

type Pipeline

type Pipeline struct {
	Transformers []transformer.Transformer
	Storage      *storage.Storage
}

Pipeline is a set of Transformations that are sequentially applied to JSON data.