registry

Documentation

Index

• func RegisterPlugin(pluginType PluginType, name string, v Plugin)
• type Plugin
  • func GetPlugin(pluginType PluginType, name string) (Plugin, error)
• type PluginType

Functions

func RegisterPlugin

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

Types

type Plugin

type Plugin interface {
	Configure(pipelineName string, data map[string]interface{}) error
}

func GetPlugin

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

type PluginType

type PluginType string

const (
	InputPlugin         PluginType = "input"
	InputPositionPlugin PluginType = "inputPosition"
	InputSchemaPlugin   PluginType = "inputSchema"
	OutputPlugin        PluginType = "output"
	OutputRulePlugin    PluginType = "outputRule"
)