(ctx context.Context, opts ...IOCloserOpts)
| 506 | } |
| 507 | |
| 508 | func (t *task) CloseIO(ctx context.Context, opts ...IOCloserOpts) error { |
| 509 | ctx, span := tracing.StartSpan(ctx, "task.CloseIO", |
| 510 | tracing.WithAttribute("task.id", t.ID()), |
| 511 | ) |
| 512 | defer span.End() |
| 513 | r := &tasks.CloseIORequest{ |
| 514 | ContainerID: t.id, |
| 515 | } |
| 516 | var i IOCloseInfo |
| 517 | for _, o := range opts { |
| 518 | o(&i) |
| 519 | } |
| 520 | r.Stdin = i.Stdin |
| 521 | |
| 522 | _, err := t.client.TaskService().CloseIO(ctx, r) |
| 523 | return errgrpc.ToNative(err) |
| 524 | } |
| 525 | |
| 526 | func (t *task) IO() cio.IO { |
| 527 | return t.io |
nothing calls this directly
no test coverage detected