burble/nomad-driver-containerd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix docs.

Browse Source
This commit is contained in:
Shishir Mahajan 2020-06-09 15:56:57 -07:00
parent fe0dfbfe4c
commit cf113e80c2
No known key found for this signature in database
GPG Key ID: D41782E7688DEC4A
2 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
containerd/driver.go
View File

@ -515,6 +515,7 @@ func (d *Driver) SignalTask(taskID string, signal string) error {
return handle.signal(d.ctxContainerd, sig)
}
// ExecTaskStreaming returns the result of executing the given command inside a task.
func (d *Driver) ExecTaskStreaming(ctx context.Context, taskID string, opts *drivers.ExecOptions) (*drivers.ExitResult, error) {
handle, ok := d.tasks.Get(taskID)
if !ok {

1
containerd/handle.go
View File

@ -82,6 +82,7 @@ func (h *taskHandle) run(ctxContainerd context.Context) {
h.task.Start(ctxContainerd)
}
// exec launches a new process in a running container.
func (h *taskHandle) exec(ctx, ctxContainerd context.Context, taskID string, opts *drivers.ExecOptions) (*drivers.ExitResult, error) {
defer opts.Stdout.Close()
defer opts.Stderr.Close()