binder

Documentation

Index

• type Entries
  • func (e Entries) Len() int
  • func (e Entries) Less(i, j int) bool
  • func (e Entries) Swap(i, j int)
• type FactoryEntry
• type FuncFactory
• type SinkFactory
• type SourceFactory

Types

type Entries

type Entries []FactoryEntry

func (Entries) Len

func (e Entries) Len() int

func (Entries) Less

func (e Entries) Less(i, j int) bool

func (Entries) Swap

func (e Entries) Swap(i, j int)

type FactoryEntry

type FactoryEntry struct {
	Name    string
	Factory interface{}
	Weight  int // bigger weight will be initialized first
}

type FuncFactory

type FuncFactory interface {
	Function(name string) (api.Function, error)
	// HasFunctionSet Some functions are bundled together into a plugin which shares the same json file.
	// This function can return if the function set name exists.
	HasFunctionSet(funcName string) bool
	// ConvName Convert the name of the function usually to lowercase.
	// This is only be used when parsing the SQL statement.
	ConvName(funcName string) (string, bool)
	// FunctionPluginInfo Use function name to get the function plugin install script
	// first return value is extension type, only native/portable plugin type have installation information
	// second return value is the plugin name
	// third is the plugin installation information
	FunctionPluginInfo(funcName string) (plugin.EXTENSION_TYPE, string, string)
}

type SinkFactory

type SinkFactory interface {
	Sink(name string) (api.Sink, error)
	// SinkPluginInfo use sink type name (mqtt/redis) to get sink plugin installation information
	// first return value is extension type, only native/portable plugin type have installation information
	// second return value is the plugin name
	// third is the plugin installation information
	SinkPluginInfo(name string) (plugin.EXTENSION_TYPE, string, string)
}

type SourceFactory

type SourceFactory interface {
	Source(name string) (api.Source, error)
	LookupSource(name string) (api.LookupSource, error)
	// SourcePluginInfo use source type name (mqtt/video) to get source plugin installation information
	// first return value is extension type, only native/portable plugin type have installation information
	// second return value is the plugin name
	// third is the plugin installation information
	SourcePluginInfo(name string) (plugin.EXTENSION_TYPE, string, string)
}