shared

type Job interface {
	InvokeService(request *protobuf.JobInvokeServiceRequest) (*protobuf.JobInvokeServiceResponse, error)
}

type Task interface {
	Execute(ctx context.Context, jobId int64, jobRequest []byte) (*protobuf.ExecuteTaskResponse, error) // 执行任务
	GetDescription() (string, error)                                                                    // 获取任务描述
}

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

type TaskPlugin struct {
	plugin.NetRPCUnsupportedPlugin
	Impl protobuf.TaskServer
}