docker

Documentation

Index

• func DockerLogs(ctx context.Context, cli Streamer, containerName string, lastMessage string) (logs.RAW, error)
• func GetDockers(ctx context.Context, c Lister, filts ...func(container2 types.Container) bool) ([]string, error)
• func New() (*client.Client, error)
• func StreamDockerLogs(ctx context.Context, cli Streamer, containerName string, logsChan chan string) error
• type Lister
• type Streamer

Functions

func DockerLogs

func DockerLogs(
	ctx context.Context,
	cli Streamer,
	containerName string,
	lastMessage string,
) (logs.RAW, error)

func GetDockers

func GetDockers(
	ctx context.Context,
	c Lister,
	filts ...func(container2 types.Container) bool,
) ([]string, error)

func New

func New() (*client.Client, error)

func StreamDockerLogs

func StreamDockerLogs(
	ctx context.Context,
	cli Streamer,
	containerName string,
	logsChan chan string,
) error

Types

type Lister

type Lister interface {
	//	ContainerRestart(ctx context.Context, containerID string, options container.StopOptions) error
	ContainerList(
		ctx context.Context,
		options types.ContainerListOptions,
	) ([]types.Container, error)
}

type Streamer

type Streamer interface {
	ContainerLogs(
		ctx context.Context,
		container string,
		options types.ContainerLogsOptions,
	) (io.ReadCloser, error)
}