portable

Documentation

Index

• type Manager
  • func InitManager() (*Manager, error)
  • func MockManager(plugins map[string]*PluginInfo) (*Manager, error)
  • func (m *Manager) ConvName(funcName string) (string, bool)
  • func (m *Manager) Delete(name string) error
  • func (m *Manager) Function(name string) (api.Function, error)
  • func (m *Manager) FunctionPluginInfo(funcName string) (plugin.EXTENSION_TYPE, string, string)
  • func (m *Manager) GetAllPlugins() map[string]string
  • func (m *Manager) GetAllPluginsStatus() map[string]string
  • func (m *Manager) GetPluginInfo(pluginName string) (*PluginInfo, bool)
  • func (m *Manager) GetPluginMeta(pt plugin.PluginType, symbolName string) (*runtime.PluginMeta, bool)
  • func (m *Manager) HasFunctionSet(funcName string) bool
  • func (m *Manager) List() []*PluginInfo
  • func (m *Manager) LookupSource(_ string) (api.Source, error)
  • func (m *Manager) PluginImport(ctx context.Context, plugins map[string]string) map[string]string
  • func (m *Manager) PluginPartialImport(ctx context.Context, plugins map[string]string) map[string]string
  • func (m *Manager) Register(p plugin.Plugin) error
  • func (m *Manager) Sink(name string) (api.Sink, error)
  • func (m *Manager) SinkPluginInfo(name string) (plugin.EXTENSION_TYPE, string, string)
  • func (m *Manager) Source(name string) (api.Source, error)
  • func (m *Manager) SourcePluginInfo(name string) (plugin.EXTENSION_TYPE, string, string)
  • func (m *Manager) UninstallAllPlugins()
• type PluginInfo
  • func (p *PluginInfo) Validate(expectedName string) (err error)

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func InitManager

func InitManager() (*Manager, error)

InitManager must only be called once

func MockManager

func MockManager(plugins map[string]*PluginInfo) (*Manager, error)

func (*Manager) ConvName

func (m *Manager) ConvName(funcName string) (string, bool)

func (*Manager) Delete

func (m *Manager) Delete(name string) error

func (*Manager) Function

func (m *Manager) Function(name string) (api.Function, error)

func (*Manager) FunctionPluginInfo

func (m *Manager) FunctionPluginInfo(funcName string) (plugin.EXTENSION_TYPE, string, string)

func (*Manager) GetAllPlugins

func (m *Manager) GetAllPlugins() map[string]string

func (*Manager) GetAllPluginsStatus

func (m *Manager) GetAllPluginsStatus() map[string]string

func (*Manager) GetPluginInfo

func (m *Manager) GetPluginInfo(pluginName string) (*PluginInfo, bool)

func (*Manager) GetPluginMeta

func (m *Manager) GetPluginMeta(pt plugin.PluginType, symbolName string) (*runtime.PluginMeta, bool)

func (*Manager) HasFunctionSet

func (m *Manager) HasFunctionSet(funcName string) bool

func (*Manager) List

func (m *Manager) List() []*PluginInfo

func (*Manager) LookupSource

func (m *Manager) LookupSource(_ string) (api.Source, error)

func (*Manager) PluginImport

func (m *Manager) PluginImport(ctx context.Context, plugins map[string]string) map[string]string

func (*Manager) PluginPartialImport

func (m *Manager) PluginPartialImport(ctx context.Context, plugins map[string]string) map[string]string

func (*Manager) Register

func (m *Manager) Register(p plugin.Plugin) error

func (*Manager) Sink

func (m *Manager) Sink(name string) (api.Sink, error)

func (*Manager) SinkPluginInfo

func (m *Manager) SinkPluginInfo(name string) (plugin.EXTENSION_TYPE, string, string)

func (*Manager) Source

func (m *Manager) Source(name string) (api.Source, error)

func (*Manager) SourcePluginInfo

func (m *Manager) SourcePluginInfo(name string) (plugin.EXTENSION_TYPE, string, string)

func (*Manager) UninstallAllPlugins

func (m *Manager) UninstallAllPlugins()

type PluginInfo

type PluginInfo struct {
	runtime.PluginMeta
	Sources   []string `json:"sources"`
	Sinks     []string `json:"sinks"`
	Functions []string `json:"functions"`
}

func (*PluginInfo) Validate

func (p *PluginInfo) Validate(expectedName string) (err error)

Validate TODO validate duplication of source, sink and functions