hive

Documentation

Index

• func LoadPluginPath(driverConfig *config.DriverConfig, pluginToolConfig map[string]interface{}) string
• type KernelCtx
• type PluginHandler
  • func InitKernel(id string) *PluginHandler
  • func (pH *PluginHandler) AddKernelPlugin(service string, driverConfig *config.DriverConfig)
  • func (pH *PluginHandler) DynamicReloader(driverConfig *config.DriverConfig)
  • func (pH *PluginHandler) GetPluginHandler(service string, driverConfig *config.DriverConfig) *PluginHandler
  • func (pluginHandler *PluginHandler) Handle_Chat(driverConfig *config.DriverConfig)
  • func (pluginHandler *PluginHandler) Init(properties *map[string]interface{})
  • func (pluginHandler *PluginHandler) LoadPluginMod(driverConfig *config.DriverConfig, pluginPath string)
  • func (pluginHandler *PluginHandler) PluginserviceStart(driverConfig *config.DriverConfig, pluginToolConfig map[string]interface{}, ...)
  • func (pluginHandler *PluginHandler) PluginserviceStop(driverConfig *config.DriverConfig)

Functions

func LoadPluginPath

func LoadPluginPath(driverConfig *config.DriverConfig, pluginToolConfig map[string]interface{}) string

Types

type KernelCtx

type KernelCtx struct {
	DeployRestartChan *chan string
	PluginRestartChan *chan core.KernelCmd
}

type PluginHandler

type PluginHandler struct {
	Name          string //service
	State         int    //0 - initialized, 1 - running, 2 - failed
	Id            string
	Signature     string //sha256 of plugin
	ConfigContext *core.ConfigContext
	Services      *map[string]*PluginHandler
	PluginMod     *plugin.Plugin
	KernelCtx     *KernelCtx
}

func InitKernel

func InitKernel(id string) *PluginHandler

func (*PluginHandler) AddKernelPlugin

func (pH *PluginHandler) AddKernelPlugin(service string, driverConfig *config.DriverConfig)

func (*PluginHandler) DynamicReloader

func (pH *PluginHandler) DynamicReloader(driverConfig *config.DriverConfig)

func (*PluginHandler) GetPluginHandler

func (pH *PluginHandler) GetPluginHandler(service string, driverConfig *config.DriverConfig) *PluginHandler

func (*PluginHandler) Handle_Chat

func (pluginHandler *PluginHandler) Handle_Chat(driverConfig *config.DriverConfig)

func (*PluginHandler) Init

func (pluginHandler *PluginHandler) Init(properties *map[string]interface{})

func (*PluginHandler) LoadPluginMod

func (pluginHandler *PluginHandler) LoadPluginMod(driverConfig *config.DriverConfig, pluginPath string)

func (*PluginHandler) PluginserviceStart

func (pluginHandler *PluginHandler) PluginserviceStart(driverConfig *config.DriverConfig, pluginToolConfig map[string]interface{}, chatReceiverChan *chan *core.ChatMsg)

func (*PluginHandler) PluginserviceStop

func (pluginHandler *PluginHandler) PluginserviceStop(driverConfig *config.DriverConfig)