registry

Nov 22, 2023

Changes in this version

+ func RegisterPlugin(pluginType PluginType, name string, v Plugin)

+ type Plugin interface

+ Configure func(pipelineName string, data map[string]interface{}) error

+ func GetPlugin(pluginType PluginType, name string) (Plugin, error)

+ type PluginType string

+ const InputPlugin

+ const InputPositionPlugin

+ const InputSchemaPlugin

+ const OutputPlugin

+ const OutputRulePlugin