Documentation
¶
Index ¶
- type IPlugin
- type MsgpackCodec
- type PluginImplement
- type PluginRPC
- func (pRPC *PluginRPC) CustomInterface(pluginOperate TPluginOperate) response.TResponse
- func (pRPC *PluginRPC) GetConfigTemplate() response.TResponse
- func (pRPC *PluginRPC) GetSystemUsage() string
- func (pRPC *PluginRPC) Run(config string) response.TResponse
- func (pRPC *PluginRPC) Running() response.TResponse
- func (pRPC *PluginRPC) Stop() response.TResponse
- type PluginRPCServer
- func (s *PluginRPCServer) CustomInterface(pluginOperate TPluginOperate, resp *response.TResponse) error
- func (s *PluginRPCServer) GetConfigTemplate(args interface{}, resp *response.TResponse) error
- func (s *PluginRPCServer) GetSystemUsage(args interface{}, resp *string) error
- func (s *PluginRPCServer) Run(config string, resp *response.TResponse) error
- func (s *PluginRPCServer) Running(args interface{}, resp *response.TResponse) error
- func (s *PluginRPCServer) Stop(args interface{}, resp *response.TResponse) error
- type TPluginInfo
- type TPluginOperate
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MsgpackCodec ¶
type MsgpackCodec struct{}
func (MsgpackCodec) Decode ¶
func (MsgpackCodec) Decode(data []byte, v interface{}) error
func (MsgpackCodec) Encode ¶
func (MsgpackCodec) Encode(v interface{}) ([]byte, error)
type PluginRPC ¶
type PluginRPC struct {
// contains filtered or unexported fields
}
func (*PluginRPC) CustomInterface ¶
func (pRPC *PluginRPC) CustomInterface(pluginOperate TPluginOperate) response.TResponse
func (*PluginRPC) GetConfigTemplate ¶
func (*PluginRPC) GetSystemUsage ¶
type PluginRPCServer ¶
type PluginRPCServer struct {
Impl IPlugin
}
func (*PluginRPCServer) CustomInterface ¶
func (s *PluginRPCServer) CustomInterface(pluginOperate TPluginOperate, resp *response.TResponse) error
func (*PluginRPCServer) GetConfigTemplate ¶
func (s *PluginRPCServer) GetConfigTemplate(args interface{}, resp *response.TResponse) error
func (*PluginRPCServer) GetSystemUsage ¶
func (s *PluginRPCServer) GetSystemUsage(args interface{}, resp *string) error
func (*PluginRPCServer) Run ¶
func (s *PluginRPCServer) Run(config string, resp *response.TResponse) error
func (s *PluginRPCServer) Load(config string, resp *response.TResponse) error {
*resp = s.Impl.Load(config)
return nil
}
type TPluginInfo ¶
type TPluginInfo struct {
PluginUUID string `json:"plugin_uuid,omitempty"` //用于创建插件的目录
PluginName string `json:"plugin_name,omitempty"` //插件名称
PluginType string `json:"plugin_type,omitempty"` //插件类型(包括:接口插件,服务插件,数据推送,数据抽取,全部插件)
PluginDesc string `json:"plugin_desc,omitempty"` //插件描述
PluginFileName string `json:"plugin_file_name,omitempty"`
PluginConfig string `json:"plugin_config,omitempty"` //插件配置信息
PluginVersion string `json:"plugin_version,omitempty"` //插件版本号
RunType string `json:"run_type,omitempty"` //启动类型(包括:自动启动、手动启动、禁止启动)
SerialNumber string `json:"serial_number,omitempty"` //用于匹配插件的序列号
Status string `json:"status,omitempty"` //插件状态(包括:待加载、待运行)
}
Click to show internal directories.
Click to hide internal directories.