native

Documentation

Index

• Constants
• type Manager
  • func InitManager() (*Manager, error)
  • func (rr *Manager) ConvName(name string) (string, bool)
  • func (rr *Manager) Delete(t plugin2.PluginType, name string, stop bool) error
  • func (rr *Manager) Function(name string) (api.Function, error)
  • func (rr *Manager) FunctionPluginInfo(funcName string) (plugin2.EXTENSION_TYPE, string, string)
  • func (rr *Manager) GetAllPlugins() map[string]string
  • func (rr *Manager) GetAllPluginsStatus() map[string]string
  • func (rr *Manager) GetPluginBySymbol(t plugin2.PluginType, symbolName string) (string, bool)
  • func (rr *Manager) GetPluginInfo(t plugin2.PluginType, name string) (map[string]interface{}, bool)
  • func (rr *Manager) GetPluginVersionBySymbol(t plugin2.PluginType, symbolName string) (string, bool)
  • func (rr *Manager) HasFunctionSet(name string) bool
  • func (rr *Manager) List(t plugin2.PluginType) []string
  • func (rr *Manager) ListSymbols() []string
  • func (rr *Manager) LookupSource(name string) (api.Source, error)
  • func (rr *Manager) PluginImport(ctx context.Context, plugins map[string]string) map[string]string
  • func (rr *Manager) PluginPartialImport(ctx context.Context, plugins map[string]string) map[string]string
  • func (rr *Manager) Register(t plugin2.PluginType, j plugin2.Plugin) error
  • func (rr *Manager) RegisterFuncs(name string, functions []string) error
  • func (rr *Manager) Sink(name string) (api.Sink, error)
  • func (rr *Manager) SinkPluginInfo(name string) (plugin2.EXTENSION_TYPE, string, string)
  • func (rr *Manager) Source(name string) (api.Source, error)
  • func (rr *Manager) SourcePluginInfo(name string) (plugin2.EXTENSION_TYPE, string, string)
  • func (rr *Manager) UninstallAllPlugins()

Constants

const BOOT_INSTALL = "$boot_install"

const DELETED = "$deleted"

Types

type Manager

type Manager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Manager is appended only because plugin cannot delete or reload. To delete a plugin, restart the server to reindex

func InitManager

func InitManager() (*Manager, error)

InitManager must only be called once

func (*Manager) ConvName

func (rr *Manager) ConvName(name string) (string, bool)

func (*Manager) Delete

func (rr *Manager) Delete(t plugin2.PluginType, name string, stop bool) error

func (*Manager) Function

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

func (*Manager) FunctionPluginInfo

func (rr *Manager) FunctionPluginInfo(funcName string) (plugin2.EXTENSION_TYPE, string, string)

func (*Manager) GetAllPlugins

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

func (*Manager) GetAllPluginsStatus

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

func (*Manager) GetPluginBySymbol

func (rr *Manager) GetPluginBySymbol(t plugin2.PluginType, symbolName string) (string, bool)

func (*Manager) GetPluginInfo

func (rr *Manager) GetPluginInfo(t plugin2.PluginType, name string) (map[string]interface{}, bool)

func (*Manager) GetPluginVersionBySymbol

func (rr *Manager) GetPluginVersionBySymbol(t plugin2.PluginType, symbolName string) (string, bool)

func (*Manager) HasFunctionSet

func (rr *Manager) HasFunctionSet(name string) bool

func (*Manager) List

func (rr *Manager) List(t plugin2.PluginType) []string

func (*Manager) ListSymbols

func (rr *Manager) ListSymbols() []string

func (*Manager) LookupSource

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

func (*Manager) PluginImport

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

PluginImport save the plugin install information and wait for restart

func (*Manager) PluginPartialImport

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

PluginPartialImport compare the plugin to be installed and the one in database if not exist in database, install; if exist, ignore

func (*Manager) Register

func (rr *Manager) Register(t plugin2.PluginType, j plugin2.Plugin) error

func (*Manager) RegisterFuncs

func (rr *Manager) RegisterFuncs(name string, functions []string) error

RegisterFuncs prerequisite：function plugin of name exists

func (*Manager) Sink

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

func (*Manager) SinkPluginInfo

func (rr *Manager) SinkPluginInfo(name string) (plugin2.EXTENSION_TYPE, string, string)

func (*Manager) Source

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

func (*Manager) SourcePluginInfo

func (rr *Manager) SourcePluginInfo(name string) (plugin2.EXTENSION_TYPE, string, string)

func (*Manager) UninstallAllPlugins

func (rr *Manager) UninstallAllPlugins()