builtin

Documentation

Index

• Variables
• type ProcessorPluginConstructor
  • func NewProcessorPluginConstructor(processorPlugin sdk.Processor) ProcessorPluginConstructor
• type Registry
  • func NewRegistry(logger log.CtxLogger, constructors map[string]ProcessorPluginConstructor) *Registry
  • func (r *Registry) List() map[plugin.FullName]sdk.Specification
  • func (r *Registry) NewProcessor(_ context.Context, fullName plugin.FullName, _ string) (sdk.Processor, error)

Variables

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,
	"error":               impl.NewErrorProcessor,
	"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,
}

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)