Documentation
¶
Index ¶
- func CreateTask(taskRequest *pb.CreateTaskRequest) (taskId string, err error)
- func DescribeTasks(taskRequest *pb.DescribeTasksRequest) (*pb.DescribeTasksResponse, error)
- func NewTaskManagerClient(ctx context.Context) (pb.TaskManagerClient, error)
- func SendTask(task *models.Task) (taskId string, err error)
- func WaitTask(taskId string, timeout time.Duration, waitInterval time.Duration) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateTask ¶
func CreateTask(taskRequest *pb.CreateTaskRequest) (taskId string, err error)
func DescribeTasks ¶
func DescribeTasks(taskRequest *pb.DescribeTasksRequest) (*pb.DescribeTasksResponse, error)
func NewTaskManagerClient ¶
func NewTaskManagerClient(ctx context.Context) (pb.TaskManagerClient, error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.