registry

Documentation

Index

• Constants
• func RegisterPlugin(pluginType PluginType, name string, v Plugin, singleton bool)
• func RegisterPluginFactory(pluginType PluginType, name string, v PluginFactory)
• type Plugin
  • func DownloadGoNativePlugin(goPluginConfig map[string]interface{}) (string, Plugin, error)
  • func GetPlugin(pluginType PluginType, name string) (Plugin, error)
• type PluginFactory
• type PluginType

Constants

const (
	PluginDir     = "./go-plugins"
	InterfaceName = "Plugin"
)

Functions

func RegisterPlugin

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

func RegisterPluginFactory

func RegisterPluginFactory(pluginType PluginType, name string, v PluginFactory)

Types

type Plugin

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

func DownloadGoNativePlugin

func DownloadGoNativePlugin(goPluginConfig map[string]interface{}) (string, Plugin, error)

func GetPlugin

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

type PluginFactory

type PluginFactory func() Plugin

type PluginType

type PluginType string

const (
	InputPlugin              PluginType = "input"
	OutputPlugin             PluginType = "output"
	FilterPlugin             PluginType = "filters"
	MatcherPlugin            PluginType = "matcher"
	SchedulerPlugin          PluginType = "scheduler"
	SQLExecutionEnginePlugin PluginType = "sqlExecutionEngine"
)