handler

Documentation

Index

• type RpcHandler
  • func NewRpcHandler(node *node.Node) *RpcHandler
  • func (h *RpcHandler) Echo(content string, reply *string) error
  • func (h *RpcHandler) QueryClusterExecutors(taskId string, reply *packet.RpcReply) error
  • func (h *RpcHandler) QueryExecutors(taskId string, reply *packet.RpcReply) error
  • func (h *RpcHandler) QueryNodes(pageInfo *core.PageInfo, reply *packet.RpcReply) error
  • func (h *RpcHandler) QueryResource(content string, reply *packet.RpcReply) error
  • func (h *RpcHandler) RegisterExecutor(config *core.TaskConfig, reply *packet.RpcReply) error
  • func (h *RpcHandler) RegisterNode(nodeInfo *core.NodeInfo, reply *packet.RpcReply) error
  • func (h *RpcHandler) RemoveExecutor(taskId string, reply *packet.RpcReply) error
  • func (h *RpcHandler) StartExecutor(taskId string, reply *packet.RpcReply) error
  • func (h *RpcHandler) StopExecutor(taskId string, reply *packet.RpcReply) error
  • func (h *RpcHandler) SubmitExecutor(execInfo *core.ExecutorInfo, reply *packet.RpcReply) error
  • func (h *RpcHandler) SubmitStartExecutor(taskId string, reply *packet.RpcReply) error
  • func (h *RpcHandler) SubmitStopExecutor(taskId string, reply *packet.RpcReply) error

Types

type RpcHandler

type RpcHandler struct {
	// contains filtered or unexported fields
}

func NewRpcHandler

func NewRpcHandler(node *node.Node) *RpcHandler

func (*RpcHandler) Echo

func (h *RpcHandler) Echo(content string, reply *string) error

Echo

func (*RpcHandler) QueryClusterExecutors

func (h *RpcHandler) QueryClusterExecutors(taskId string, reply *packet.RpcReply) error

QueryClusterExecutorInfos return executor info in cluster by taskId

func (*RpcHandler) QueryExecutors

func (h *RpcHandler) QueryExecutors(taskId string, reply *packet.RpcReply) error

QueryExecutors return executors in runtime by taskId if taskId is nil, return all executors

func (*RpcHandler) QueryNodes

func (h *RpcHandler) QueryNodes(pageInfo *core.PageInfo, reply *packet.RpcReply) error

QueryNodes query node list from leader

func (*RpcHandler) QueryResource

func (h *RpcHandler) QueryResource(content string, reply *packet.RpcReply) error

QueryResource query resource info from worker node

func (*RpcHandler) RegisterExecutor

func (h *RpcHandler) RegisterExecutor(config *core.TaskConfig, reply *packet.RpcReply) error

RegisterExecutor register executor to runtime in worker node

func (*RpcHandler) RegisterNode

func (h *RpcHandler) RegisterNode(nodeInfo *core.NodeInfo, reply *packet.RpcReply) error

RegisterWorker register worker node to leader it will check cluster id

func (*RpcHandler) RemoveExecutor

func (h *RpcHandler) RemoveExecutor(taskId string, reply *packet.RpcReply) error

RemoveExecutor remove executor by taskId if task is running, auto stop it first

func (*RpcHandler) StartExecutor

func (h *RpcHandler) StartExecutor(taskId string, reply *packet.RpcReply) error

StartExecutor start executor by taskId

func (*RpcHandler) StopExecutor

func (h *RpcHandler) StopExecutor(taskId string, reply *packet.RpcReply) error

StopExecutor stop executor by taskId

func (*RpcHandler) SubmitExecutor

func (h *RpcHandler) SubmitExecutor(execInfo *core.ExecutorInfo, reply *packet.RpcReply) error

SubmitExecutor submit executor to leader node, then register to worker node it will check cluster id

func (*RpcHandler) SubmitStartExecutor

func (h *RpcHandler) SubmitStartExecutor(taskId string, reply *packet.RpcReply) error

SubmitStartExecutor

func (*RpcHandler) SubmitStopExecutor

func (h *RpcHandler) SubmitStopExecutor(taskId string, reply *packet.RpcReply) error

SubmitStopExecutor