Add CloseStdin to exec Process

Signed-off-by: Michael Crosby <crosbymichael@gmail.com>
This commit is contained in:
Michael Crosby 2017-05-31 15:55:07 -07:00
parent 9890bed1e1
commit 1db752bca8
2 changed files with 9 additions and 0 deletions

View File

@ -88,3 +88,11 @@ func (p *process) Wait(ctx context.Context) (uint32, error) {
}
}
}
func (p *process) CloseStdin(ctx context.Context) error {
_, err := p.task.client.TaskService().CloseStdin(ctx, &execution.CloseStdinRequest{
ContainerID: p.task.containerID,
Pid: p.pid,
})
return err
}

View File

@ -40,6 +40,7 @@ type Process interface {
Start(context.Context) error
Kill(context.Context, syscall.Signal) error
Wait(context.Context) (uint32, error)
CloseStdin(context.Context) error
}
var _ = (Task)(&task{})