binder

package
v1.14.0-dev.1 Latest Latest
Warning

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

Go to latest
Published: Mar 25, 2024 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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