Documentation
¶
Index ¶
- func CancelTaskLocal(taskId string, nodeId string) error
- func CancelTaskRemote(taskId string, nodeId string) (err error)
- func ClientFunc(msg entity.RpcMessage) func() (entity.RpcMessage, error)
- func GetInstalledDepsLocal(lang string) (deps []entity.Dependency, err error)
- func GetInstalledDepsRemote(nodeId string, lang string) (deps []entity.Dependency, err error)
- func GetLangLocal(lang entity.Lang) entity.Lang
- func GetLangRemote(nodeId string, lang entity.Lang) (l entity.Lang, err error)
- func GetNodejsInstalledDepListLocal() ([]entity.Dependency, error)
- func GetPythonInstalledDepListLocal() ([]entity.Dependency, error)
- func GetSystemInfoServiceLocal() (sysInfo entity.SystemInfo, err error)
- func GetSystemInfoServiceRemote(nodeId string) (sysInfo entity.SystemInfo, err error)
- func InitRpcService() error
- func InstallDepLocal(lang string, depName string) error
- func InstallDepRemote(nodeId string, lang string, depName string) (err error)
- func InstallLangLocal(lang string) (o string, err error)
- func InstallLangRemote(nodeId string, lang string) (o string, err error)
- func InstallNodejsDepLocal(depName string) (string, error)
- func InstallPythonDepLocal(depName string) (string, error)
- func RemoveSpiderServiceLocal(spiderId string) error
- func RemoveSpiderServiceRemote(spiderId string, nodeId string) (err error)
- func UninstallDepLocal(lang string, depName string) error
- func UninstallDepRemote(nodeId string, lang string, depName string) (err error)
- func UninstallNodejsDepLocal(depName string) (string, error)
- func UninstallPythonDepLocal(depName string) (string, error)
- type CancelTaskService
- type GetInstalledDepsService
- type GetLangService
- type GetSystemInfoService
- type InstallDepService
- type InstallLangService
- type RemoveSpiderService
- type Service
- type UninstallDepService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CancelTaskLocal ¶
func CancelTaskRemote ¶
func ClientFunc ¶
func ClientFunc(msg entity.RpcMessage) func() (entity.RpcMessage, error)
客户端处理消息函数
func GetInstalledDepsLocal ¶
func GetInstalledDepsLocal(lang string) (deps []entity.Dependency, err error)
获取本地已安装依赖列表
func GetInstalledDepsRemote ¶
func GetInstalledDepsRemote(nodeId string, lang string) (deps []entity.Dependency, err error)
func GetNodejsInstalledDepListLocal ¶
func GetNodejsInstalledDepListLocal() ([]entity.Dependency, error)
获取Node.js本地已安装依赖列表
func GetPythonInstalledDepListLocal ¶
func GetPythonInstalledDepListLocal() ([]entity.Dependency, error)
获取Python本地已安装依赖列表
func GetSystemInfoServiceLocal ¶
func GetSystemInfoServiceLocal() (sysInfo entity.SystemInfo, err error)
func GetSystemInfoServiceRemote ¶
func GetSystemInfoServiceRemote(nodeId string) (sysInfo entity.SystemInfo, err error)
func InstallDepLocal ¶
func InstallDepRemote ¶
func InstallLangRemote ¶
远端安装语言
func InstallNodejsDepLocal ¶
func InstallPythonDepLocal ¶
安装Python本地依赖
func UninstallDepLocal ¶
func UninstallDepRemote ¶
func UninstallNodejsDepLocal ¶
func UninstallPythonDepLocal ¶
Types ¶
type CancelTaskService ¶
type CancelTaskService struct {
// contains filtered or unexported fields
}
func (*CancelTaskService) ClientHandle ¶
func (s *CancelTaskService) ClientHandle() (o interface{}, err error)
func (*CancelTaskService) ServerHandle ¶
func (s *CancelTaskService) ServerHandle() (entity.RpcMessage, error)
type GetInstalledDepsService ¶
type GetInstalledDepsService struct {
// contains filtered or unexported fields
}
func (*GetInstalledDepsService) ClientHandle ¶
func (s *GetInstalledDepsService) ClientHandle() (o interface{}, err error)
func (*GetInstalledDepsService) ServerHandle ¶
func (s *GetInstalledDepsService) ServerHandle() (entity.RpcMessage, error)
type GetLangService ¶
type GetLangService struct {
// contains filtered or unexported fields
}
func (*GetLangService) ClientHandle ¶
func (s *GetLangService) ClientHandle() (o interface{}, err error)
func (*GetLangService) ServerHandle ¶
func (s *GetLangService) ServerHandle() (entity.RpcMessage, error)
type GetSystemInfoService ¶
type GetSystemInfoService struct {
// contains filtered or unexported fields
}
func (*GetSystemInfoService) ClientHandle ¶
func (s *GetSystemInfoService) ClientHandle() (o interface{}, err error)
func (*GetSystemInfoService) ServerHandle ¶
func (s *GetSystemInfoService) ServerHandle() (entity.RpcMessage, error)
type InstallDepService ¶
type InstallDepService struct {
// contains filtered or unexported fields
}
func (*InstallDepService) ClientHandle ¶
func (s *InstallDepService) ClientHandle() (o interface{}, err error)
func (*InstallDepService) ServerHandle ¶
func (s *InstallDepService) ServerHandle() (entity.RpcMessage, error)
type InstallLangService ¶
type InstallLangService struct {
// contains filtered or unexported fields
}
func (*InstallLangService) ClientHandle ¶
func (s *InstallLangService) ClientHandle() (o interface{}, err error)
func (*InstallLangService) ServerHandle ¶
func (s *InstallLangService) ServerHandle() (entity.RpcMessage, error)
type RemoveSpiderService ¶
type RemoveSpiderService struct {
// contains filtered or unexported fields
}
func (*RemoveSpiderService) ClientHandle ¶
func (s *RemoveSpiderService) ClientHandle() (o interface{}, err error)
func (*RemoveSpiderService) ServerHandle ¶
func (s *RemoveSpiderService) ServerHandle() (entity.RpcMessage, error)
type Service ¶
type Service interface {
ServerHandle() (entity.RpcMessage, error)
ClientHandle() (interface{}, error)
}
RPC服务基础类
type UninstallDepService ¶
type UninstallDepService struct {
// contains filtered or unexported fields
}
func (*UninstallDepService) ClientHandle ¶
func (s *UninstallDepService) ClientHandle() (o interface{}, err error)
func (*UninstallDepService) ServerHandle ¶
func (s *UninstallDepService) ServerHandle() (entity.RpcMessage, error)
Source Files
Click to show internal directories.
Click to hide internal directories.