docker

Documentation

Index

• type Client
  • func NewClient(dockerClient *client.Client) *Client
  • func (c *Client) FetchContainerLogs(ctx context.Context, query log.Query) (io.ReadCloser, error)
  • func (c *Client) ListContainers(ctx context.Context) ([]log.Container, error)
  • func (c *Client) WatchContainersStart(ctx context.Context) (<-chan log.Container, <-chan error)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client is an adapter for the Docker Engine API client to our domain.

func NewClient

func NewClient(dockerClient *client.Client) *Client

NewClient returns a new Client wrapping the given Docker Engine API client.

func (*Client) FetchContainerLogs

func (c *Client) FetchContainerLogs(ctx context.Context, query log.Query) (io.ReadCloser, error)

FetchContainerLogs returns a filtered stream of logs from the specified Docker container. If the container cannot be found it returns a *log.Error.

func (*Client) ListContainers

func (c *Client) ListContainers(ctx context.Context) ([]log.Container, error)

ListContainers fetches the list of all containers in Docker (docker ps -a).

func (*Client) WatchContainersStart

func (c *Client) WatchContainersStart(ctx context.Context) (<-chan log.Container, <-chan error)

WatchContainersStart returns a stream of events the caller can consume to be notified when a new running container is detected.