dockerutil

Documentation

Index

• func FakePull(img image.Image, w io.Writer) error
• func NewDockerClient(socket, certPath string) (*docker.Client, error)
• func NewDockerClientFromEnv() (*docker.Client, error)
• type Client
  • func NewClient(authProvider dockerauth.AuthProvider, socket, certPath string) (*Client, error)
  • func NewClientFromEnv(authProvider dockerauth.AuthProvider) (*Client, error)
  • func (c *Client) AttachToContainer(ctx context.Context, opts docker.AttachToContainerOptions) error
  • func (c *Client) CreateContainer(ctx context.Context, opts docker.CreateContainerOptions) (*docker.Container, error)
  • func (c *Client) PullImage(ctx context.Context, opts docker.PullImageOptions) error
  • func (c *Client) RemoveContainer(ctx context.Context, opts docker.RemoveContainerOptions) error
  • func (c *Client) StartContainer(ctx context.Context, id string, config *docker.HostConfig) error
  • func (c *Client) StopContainer(ctx context.Context, id string, timeout uint) error
• type DecodedJSONMessageWriter
  • func DecodeJSONMessageStream(w io.Writer) *DecodedJSONMessageWriter
  • func (w *DecodedJSONMessageWriter) Err() error
  • func (w *DecodedJSONMessageWriter) Write(b []byte) (int, error)

Functions

func FakePull

func FakePull(img image.Image, w io.Writer) error

FakePull writes a jsonmessage stream to w that looks like a Docker pull.

func NewDockerClient

func NewDockerClient(socket, certPath string) (*docker.Client, error)

NewDockerClient returns a new docker.Client using the given socket and certificate path.

func NewDockerClientFromEnv

func NewDockerClientFromEnv() (*docker.Client, error)

NewDockerClientFromEnv returns a new docker client configured by the DOCKER_* environment variables.

Types

type Client

type Client struct {
	*docker.Client

	// AuthProvider is the dockerauth.AuthProvider that will be used for pulling
	// images.
	AuthProvider dockerauth.AuthProvider
}

Client wraps a docker.Client to authenticate pulls.

func NewClient

func NewClient(authProvider dockerauth.AuthProvider, socket, certPath string) (*Client, error)

NewClient returns a new Client instance.

func NewClientFromEnv

func NewClientFromEnv(authProvider dockerauth.AuthProvider) (*Client, error)

NewClientFromEnv returns a new Client instance configured by the DOCKER_* environment variables.

func (*Client) AttachToContainer

func (c *Client) AttachToContainer(ctx context.Context, opts docker.AttachToContainerOptions) error

func (*Client) CreateContainer

func (c *Client) CreateContainer(ctx context.Context, opts docker.CreateContainerOptions) (*docker.Container, error)

func (*Client) PullImage

func (c *Client) PullImage(ctx context.Context, opts docker.PullImageOptions) error

PullImage wraps the docker clients PullImage to handle authentication.

func (*Client) RemoveContainer

func (c *Client) RemoveContainer(ctx context.Context, opts docker.RemoveContainerOptions) error

func (*Client) StartContainer

func (c *Client) StartContainer(ctx context.Context, id string, config *docker.HostConfig) error

func (*Client) StopContainer

func (c *Client) StopContainer(ctx context.Context, id string, timeout uint) error

type DecodedJSONMessageWriter

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

DecodedJSONMessageWriter is an io.Writer that decodes a jsonmessage stream.

func DecodeJSONMessageStream

func DecodeJSONMessageStream(w io.Writer) *DecodedJSONMessageWriter

DecodeJSONMessageStream wraps an io.Writer to decode a jsonmessage stream into plain text. Bytes written to w represent the decoded plain text stream.

func (*DecodedJSONMessageWriter) Err

func (w *DecodedJSONMessageWriter) Err() error

Err returns the jsonmessage.Error that occurred, if any.

func (*DecodedJSONMessageWriter) Write

func (w *DecodedJSONMessageWriter) Write(b []byte) (int, error)

Write decodes the jsonmessage stream in the bytes, and writes the decoded plain text to the underlying io.Writer.