builtin

Documentation

Index

• Variables
• type ProcessorPluginConstructor
  • func Constructor[T sdk.Processor](p func(log.CtxLogger) T) 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),
	"clone":               Constructor(impl.NewCloneProcessor),
	"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),
	"ollama.request":      Constructor(ollama.NewOllamaProcessor),
	"openai.embed":        Constructor(openai.NewEmbeddingsProcessor),
	"openai.textgen":      Constructor(openai.NewTextgenProcessor),
	"split":               Constructor(impl.NewSplitProcessor),
	"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

func Constructor

func Constructor[T sdk.Processor](p func(log.CtxLogger) T) ProcessorPluginConstructor

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)