read.go

read.go

package docker

import (
	"context"
	"io"

	"github.com/ory/dockertest"
	"github.com/ory/dockertest/docker"
)

type Container struct {
	pool     *dockertest.Pool
	resource *dockertest.Resource
}

func NewContainer(pool, repository, tag string, env []string) (*Container, error) {
	p, err := dockertest.NewPool(pool)
	if err != nil {
		return nil, err
	}

	r, err := p.Run(repository, tag, env)
	if err != nil {
		return nil, err
	}

	return &Container{
		pool:     p,
		resource: r,
	}, nil
}

func (c *Container) TailLogs(ctx context.Context, wr io.Writer, follow bool) error {
	opts := docker.LogsOptions{
		Context: ctx,

		Stderr:      true,
		Stdout:      true,
		Follow:      follow,
		Timestamps:  true,
		RawTerminal: true,

		Container: c.resource.Container.ID,

		OutputStream: wr,
	}

	return c.pool.Client.Logs(opts)
}

Excellent find!