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":         constructor(avro.NewDecodeProcessor),
	"avro.encode":         constructor(avro.NewEncodeProcessor),
	"base64.decode":       constructor(base64.NewDecodeProcessor),
	"base64.encode":       constructor(base64.NewEncodeProcessor),
	"cohere.command":      constructor(cohere.NewCommandProcessor),
	"cohere.embed":        constructor(cohere.NewEmbedProcessor),
	"cohere.rerank":       constructor(cohere.NewRerankProcessor),
	"custom.javascript":   constructor(custom.NewJavascriptProcessor),
	"error":               constructor(impl.NewErrorProcessor),
	"filter":              constructor(impl.NewFilterProcessor),
	"field.convert":       constructor(field.NewConvertProcessor),
	"field.exclude":       constructor(field.NewExcludeProcessor),
	"field.rename":        constructor(field.NewRenameProcessor),
	"field.set":           constructor(field.NewSetProcessor),
	"json.decode":         constructor(json.NewDecodeProcessor),
	"json.encode":         constructor(json.NewEncodeProcessor),
	"openai.embed":        constructor(openai.NewEmbeddingsProcessor),
	"openai.textgen":      constructor(openai.NewTextgenProcessor),
	"unwrap.debezium":     constructor(unwrap.NewDebeziumProcessor),
	"unwrap.kafkaconnect": constructor(unwrap.NewKafkaConnectProcessor),
	"unwrap.opencdc":      constructor(unwrap.NewOpenCDCProcessor),
	"webhook.http":        constructor(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)