Method CloseIO

client/process.go:196–212

(ctx context.Context, opts ...IOCloserOpts)

}

func (p *process) CloseIO(ctx context.Context, opts ...IOCloserOpts) error {
	ctx, span := tracing.StartSpan(ctx, "process.CloseIO",
		tracing.WithAttribute("process.id", p.ID()),
	)
	defer span.End()
	r := &tasks.CloseIORequest{
		ContainerID: p.task.id,
		ExecID:      p.id,
	}
	var i IOCloseInfo
	for _, o := range opts {
		o(&i)
	}
	r.Stdin = i.Stdin
	_, err := p.task.client.TaskService().CloseIO(ctx, r)
	return errgrpc.ToNative(err)
}

func (p *process) IO() cio.IO {
	return p.io