container

Documentation

Index

• func ContainerWaitWrapper(ctx context.Context, docker DockerClient, container string, ...) (<-chan dcontainer.WaitResponse, <-chan error)
• func RunWithHandler(ctx context.Context, docker DockerClient, ctrID string, handler Handler) error
• type DockerClient
• type Handler
  • func DefaultHandler(out, errOut io.Writer) Handler

Functions

func ContainerWaitWrapper

func ContainerWaitWrapper(ctx context.Context, docker DockerClient, container string, condition dcontainer.WaitCondition) (<-chan dcontainer.WaitResponse, <-chan error)

func RunWithHandler

func RunWithHandler(ctx context.Context, docker DockerClient, ctrID string, handler Handler) error

Types

type DockerClient

type DockerClient interface {
	ContainerWait(ctx context.Context, container string, condition dcontainer.WaitCondition) (<-chan dcontainer.WaitResponse, <-chan error)
	ContainerAttach(ctx context.Context, container string, options dcontainer.AttachOptions) (types.HijackedResponse, error)
	ContainerStart(ctx context.Context, container string, options dcontainer.StartOptions) error
}

type Handler

type Handler func(bodyChan <-chan dcontainer.WaitResponse, errChan <-chan error, reader io.Reader) error

func DefaultHandler

func DefaultHandler(out, errOut io.Writer) Handler