|
@ -99,6 +99,7 @@ func init() { |
|
|
|
|
|
|
|
|
type TaskService interface { |
|
|
type TaskService interface { |
|
|
DoTask(in *Request, out *Response) error |
|
|
DoTask(in *Request, out *Response) error |
|
|
|
|
|
DoCycleTask(in *Request, out *Response) error |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// AcceptTaskServiceClient accepts connections on the listener and serves requests
|
|
|
// AcceptTaskServiceClient accepts connections on the listener and serves requests
|
|
@ -173,6 +174,9 @@ func NewTaskServiceClient(conn io.ReadWriteCloser) (*TaskServiceClient, *rpc.Cli |
|
|
func (c *TaskServiceClient) DoTask(in *Request, out *Response) error { |
|
|
func (c *TaskServiceClient) DoTask(in *Request, out *Response) error { |
|
|
return c.Call("TaskService.DoTask", in, out) |
|
|
return c.Call("TaskService.DoTask", in, out) |
|
|
} |
|
|
} |
|
|
|
|
|
func (c *TaskServiceClient) DoCycleTask(in *Request, out *Response) error { |
|
|
|
|
|
return c.Call("TaskService.DoCycleTask", in, out) |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
// DialTaskService connects to an TaskService at the specified network address.
|
|
|
// DialTaskService connects to an TaskService at the specified network address.
|
|
|
func DialTaskService(network, addr string) (*TaskServiceClient, *rpc.Client, error) { |
|
|
func DialTaskService(network, addr string) (*TaskServiceClient, *rpc.Client, error) { |
|
|