pipeline

package
v1.13.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 3, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Handler

type Handler struct {
	ContextPipeline *Pipeline
	DataPipeline    *Pipeline
	// contains filtered or unexported fields
}

Handler contains Pipelines for CE transformations and CloudEvents client.

func NewHandler

func NewHandler(context, data []v1alpha1.Transform) (Handler, error)

NewHandler creates Handler instance.

func (*Handler) Start

func (t *Handler) Start(ctx context.Context, sink string) error

Start runs CloudEvent receiver and applies transformation Pipeline on incoming events.

type Pipeline

type Pipeline struct {
	Transformers []transformer.Transformer
}

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

Directories

Path Synopsis
common
add

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL