Documentation ¶
Index ¶
- type RpcClient
- func (c *RpcClient) CallEcho(message string) (error, string)
- func (c *RpcClient) CallQueryClusterExecutors(taskId string) (error, *packet.RpcReply)
- func (c *RpcClient) CallQueryExecutors(taskId string) (error, *packet.RpcReply)
- func (c *RpcClient) CallQueryNodes(pageInfo *core.PageInfo) (error, *packet.RpcReply)
- func (c *RpcClient) CallQueryResource() (error, *packet.RpcReply)
- func (c *RpcClient) CallRegisterExecutor(conf *core.TaskConfig) (error, *packet.RpcReply)
- func (c *RpcClient) CallRegisterNode(worker *core.NodeInfo) (error, *packet.RpcReply)
- func (c *RpcClient) CallRemoveExecutor(taskId string) (error, *packet.RpcReply)
- func (c *RpcClient) CallStartExecutor(taskId string) (error, *packet.RpcReply)
- func (c *RpcClient) CallStopExecutor(taskId string) (error, *packet.RpcReply)
- func (c *RpcClient) CallSubmitExecutor(execInfo *core.ExecutorInfo) (error, *packet.RpcReply)
- func (c *RpcClient) CallSubmitStartExecutor(taskId string) (error, *packet.RpcReply)
- func (c *RpcClient) CallSubmitStopExecutor(taskId string) (error, *packet.RpcReply)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RpcClient ¶
type RpcClient struct {
// contains filtered or unexported fields
}
func NewRpcClient ¶
func (*RpcClient) CallQueryClusterExecutors ¶
func (*RpcClient) CallQueryExecutors ¶
func (*RpcClient) CallQueryNodes ¶
func (*RpcClient) CallQueryResource ¶
func (*RpcClient) CallRegisterExecutor ¶
func (*RpcClient) CallRegisterNode ¶
func (*RpcClient) CallRemoveExecutor ¶
func (*RpcClient) CallStartExecutor ¶
func (*RpcClient) CallStopExecutor ¶
func (*RpcClient) CallSubmitExecutor ¶
func (*RpcClient) CallSubmitStartExecutor ¶
Click to show internal directories.
Click to hide internal directories.