(ctx context.Context)
| 322 | } |
| 323 | |
| 324 | func (t *task) Status(ctx context.Context) (Status, error) { |
| 325 | r, err := t.client.TaskService().Get(ctx, &tasks.GetRequest{ |
| 326 | ContainerID: t.id, |
| 327 | }) |
| 328 | if err != nil { |
| 329 | return Status{}, errgrpc.ToNative(err) |
| 330 | } |
| 331 | status := ProcessStatus(strings.ToLower(r.Process.Status.String())) |
| 332 | exitStatus := r.Process.ExitStatus |
| 333 | exitTime := protobuf.FromTimestamp(r.Process.ExitedAt) |
| 334 | |
| 335 | return Status{ |
| 336 | Status: status, |
| 337 | ExitStatus: exitStatus, |
| 338 | ExitTime: exitTime, |
| 339 | }, nil |
| 340 | } |
| 341 | |
| 342 | func (t *task) Wait(ctx context.Context) (<-chan ExitStatus, error) { |
| 343 | c := make(chan ExitStatus, 1) |
no test coverage detected