builtin

Documentation

Index

• Variables
• type 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, id 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

type Registry

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

func NewRegistry

func NewRegistry(
	logger log.CtxLogger,
	constructors map[string]ProcessorPluginConstructor,
	schemaRegistry schemaregistry.Registry,
) *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, id string) (sdk.Processor, error)