rpc

Documentation

Index

• Constants
• type TaskClient
  • func NewTaskClient() *TaskClient
  • func (i TaskClient) CancelExec(ctx kratosx.Context, req *types.CancelExecRequest) error
  • func (i TaskClient) CheckHealthy(ctx kratosx.Context, req *types.CheckWorkerRequest) error
  • func (i TaskClient) ExecTask(ctx kratosx.Context, req *types.ExecTaskRequest, ...) error

Constants

const (
	TaskClientServer = "TaskClient"
)

Types

type TaskClient

type TaskClient struct {
}

func NewTaskClient

func NewTaskClient() *TaskClient

func (TaskClient) CancelExec

func (i TaskClient) CancelExec(ctx kratosx.Context, req *types.CancelExecRequest) error

func (TaskClient) CheckHealthy

func (i TaskClient) CheckHealthy(ctx kratosx.Context, req *types.CheckWorkerRequest) error

func (TaskClient) ExecTask

func (i TaskClient) ExecTask(ctx kratosx.Context, req *types.ExecTaskRequest, recv func(msg *types.ExecTaskLog)) error