builtin

package
v0.10.0 Latest Latest
Warning

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

Go to latest
Published: Apr 25, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var DefaultBuiltinProcessors = map[string]ProcessorPluginConstructor{
	"avro.decode":         avro.NewDecodeProcessor,
	"avro.encode":         avro.NewEncodeProcessor,
	"base64.decode":       base64.NewDecodeProcessor,
	"base64.encode":       base64.NewEncodeProcessor,
	"custom.javascript":   custom.NewJavascriptProcessor,
	"filter":              impl.NewFilterProcessor,
	"field.convert":       field.NewConvertProcessor,
	"field.exclude":       field.NewExcludeProcessor,
	"field.rename":        field.NewRenameProcessor,
	"field.set":           field.NewSetProcessor,
	"json.decode":         json.NewDecodeProcessor,
	"json.encode":         json.NewEncodeProcessor,
	"unwrap.debezium":     unwrap.NewDebeziumProcessor,
	"unwrap.kafkaconnect": unwrap.NewKafkaConnectProcessor,
	"unwrap.opencdc":      unwrap.NewOpenCDCProcessor,
	"webhook.http":        webhook.NewHTTPProcessor,
}

Functions

This section is empty.

Types

type ProcessorPluginConstructor

type ProcessorPluginConstructor func(log.CtxLogger) sdk.Processor

func NewProcessorPluginConstructor

func NewProcessorPluginConstructor(processorPlugin sdk.Processor) ProcessorPluginConstructor

type Registry

type Registry struct {
	// contains filtered or unexported fields
}

func NewRegistry

func NewRegistry(logger log.CtxLogger, constructors map[string]ProcessorPluginConstructor) *Registry

func (*Registry) List

func (r *Registry) List() map[plugin.FullName]sdk.Specification

func (*Registry) NewProcessor

func (r *Registry) NewProcessor(_ context.Context, fullName plugin.FullName, _ string) (sdk.Processor, error)

Directories

Path Synopsis
avro
Package avro is a generated GoMock package.
Package avro is a generated GoMock package.
diff
Package diff computes differences between text files or strings.
Package diff computes differences between text files or strings.
diff/difftest
Package difftest supplies a set of tests that will operate on any implementation of a diff algorithm as exposed by "github.com/conduitio/conduit/pkg/plugin/processor/builtin/internal/diff"
Package difftest supplies a set of tests that will operate on any implementation of a diff algorithm as exposed by "github.com/conduitio/conduit/pkg/plugin/processor/builtin/internal/diff"
diff/lcs
package lcs contains code to find longest-common-subsequences (and diffs)
package lcs contains code to find longest-common-subsequences (and diffs)

Jump to

Keyboard shortcuts

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