(taskID string)
| 727 | } |
| 728 | |
| 729 | func (d *Driver) InspectTask(taskID string) (*drivers.TaskStatus, error) { |
| 730 | d.logger.Info("InspectTask", "taskID", taskID) |
| 731 | handle, ok := d.tasks.Get(taskID) |
| 732 | if !ok { |
| 733 | return nil, drivers.ErrTaskNotFound |
| 734 | } |
| 735 | |
| 736 | return handle.TaskStatus() |
| 737 | } |
| 738 | |
| 739 | func (d *Driver) TaskStats(ctx context.Context, taskID string, interval time.Duration) (<-chan *drivers.TaskResourceUsage, error) { |
| 740 | ch := make(chan *drivers.TaskResourceUsage) |
nothing calls this directly
no test coverage detected