registry

package
v0.9.2 Latest Latest
Warning

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

Go to latest
Published: Dec 28, 2018 License: Apache-2.0 Imports: 8 Imported by: 0

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 DownloadGoPlugin

func DownloadGoPlugin(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"
)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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