registry

package
v0.9.71 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 29, 2020 License: Apache-2.0 Imports: 8 Imported by: 18

Documentation

Index

Constants

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

Variables

This section is empty.

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 added in v0.9.22

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"
	PositionRepo             PluginType = "positionRepo"
	OutputPlugin             PluginType = "output"
	FilterPlugin             PluginType = "filters"
	MatcherPlugin            PluginType = "matcher"
	SchedulerPlugin          PluginType = "scheduler"
	SQLExecutionEnginePlugin PluginType = "sqlExecutionEngine"
)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL