Function Exec

integration/internal/container/exec.go:49–86

Exec executes a command inside a container, returning the result containing stdout, stderr, and exit code. Note: - this is a synchronous operation; - cmd stdin is closed.

(ctx context.Context, apiClient client.APIClient, id string, cmd []string, ops ...func(*client.ExecCreateOptions))

//   - this is a synchronous operation;
//   - cmd stdin is closed.
func Exec(ctx context.Context, apiClient client.APIClient, id string, cmd []string, ops ...func(*client.ExecCreateOptions)) (ExecResult, error) {
	// prepare exec
	execOptions := client.ExecCreateOptions{
		AttachStdout: true,
		AttachStderr: true,
		Cmd:          cmd,
	}

	for _, op := range ops {
		op(&execOptions)
	}

	res, err := apiClient.ExecCreate(ctx, id, execOptions)
	if err != nil {
		return ExecResult{}, err
	}
	execID := res.ID

	// run it, with stdout/stderr attached
	aresp, err := apiClient.ExecAttach(ctx, execID, client.ExecAttachOptions{})
	if err != nil {
		return ExecResult{}, err
	}

	// read the output
	s, err := demultiplexStreams(ctx, aresp.HijackedResponse)
	if err != nil {
		return ExecResult{}, err
	}

	// get the exit code
	inspect, err := apiClient.ExecInspect(ctx, execID, client.ExecInspectOptions{})
	if err != nil {
		return ExecResult{}, err
	}

	return ExecResult{ExitCode: inspect.ExitCode, outBuffer: &s.stdout, errBuffer: &s.stderr}, nil
}

// ExecT calls Exec() and aborts the test if an error occurs.
func ExecT(ctx context.Context, t testing.TB, apiClient client.APIClient, id string, cmd []string, ops ...func(*client.ExecCreateOptions)) ExecResult {