Method getContainerStreams

pkg/compose/attach.go:139–162

(ctx context.Context, container string)

}

func (s *composeService) getContainerStreams(ctx context.Context, container string) (io.ReadCloser, error) {
	cnx, err := s.apiClient().ContainerAttach(ctx, container, client.ContainerAttachOptions{
		Stream: true,
		Stdin:  false,
		Stdout: true,
		Stderr: true,
		Logs:   false,
	})
	if err == nil {
		stdout := ContainerStdout{HijackedResponse: cnx.HijackedResponse}
		return stdout, nil
	}

	// Fallback to logs API
	logs, err := s.apiClient().ContainerLogs(ctx, container, client.ContainerLogsOptions{
		ShowStdout: true,
		ShowStderr: true,
		Follow:     true,
	})
	if err != nil {
		return nil, err
	}
	return logs, nil
}