docker

Documentation

Index

• Constants
• func CreateContainer(ctx context.Context, dClient *client.Client, hostname string, ...) (container.ContainerCreateCreatedBody, error)
• func DoCopyToContainer(ctx context.Context, dClient *client.Client, ...) error
• func DoRemoveContainer(ctx context.Context, dClient *client.Client, containerName, hostname string) error
• func DoRestartContainer(ctx context.Context, dClient *client.Client, containerName, hostname string) error
• func DoRollingUpdateContainer(ctx context.Context, dClient *client.Client, imageCfg *container.Config, ...) error
• func DoRunContainer(ctx context.Context, dClient *client.Client, imageCfg *container.Config, ...) error
• func DoRunOnetimeContainer(ctx context.Context, dClient *client.Client, imageCfg *container.Config, ...) error
• func DoesContainerExist(ctx context.Context, dClient *client.Client, hostname string, ...) (bool, error)
• func FindContainer(ctx context.Context, dClient *client.Client, hostname string, ...) (*types.Container, error)
• func GetContainerLogsStdoutStderr(ctx context.Context, dClient *client.Client, containerName, tail string, ...) (string, string, error)
• func GetContainerOutput(ctx context.Context, dClient *client.Client, containerName, hostname string, ...) (int64, string, string, error)
• func GetImageRegistryConfig(image string, prsMap map[string]v3.PrivateRegistry) (string, string, error)
• func GetKubeletDockerConfig(prsMap map[string]v3.PrivateRegistry) (string, error)
• func InspectContainer(ctx context.Context, dClient *client.Client, hostname string, ...) (types.ContainerJSON, error)
• func IsContainerRunning(ctx context.Context, dClient *client.Client, hostname string, ...) (bool, error)
• func IsContainerUpgradable(ctx context.Context, dClient *client.Client, imageCfg *container.Config, ...) (bool, error)
• func IsSupportedDockerVersion(info types.Info, K8sVersion string) (bool, error)
• func ReadContainerLogs(ctx context.Context, dClient *client.Client, containerName string, follow bool, ...) (io.ReadCloser, error)
• func ReadFileFromContainer(ctx context.Context, dClient *client.Client, ...) (string, error)
• func RemoveContainer(ctx context.Context, dClient *client.Client, hostname string, ...) error
• func RenameContainer(ctx context.Context, dClient *client.Client, hostname string, ...) error
• func RestartContainer(ctx context.Context, dClient *client.Client, hostname, containerName string) error
• func StartContainer(ctx context.Context, dClient *client.Client, hostname string, ...) error
• func StopContainer(ctx context.Context, dClient *client.Client, hostname string, ...) error
• func StopRenameContainer(ctx context.Context, dClient *client.Client, hostname string, ...) error
• func UseLocalOrPull(ctx context.Context, dClient *client.Client, hostname string, ...) error
• func WaitForContainer(ctx context.Context, dClient *client.Client, hostname string, ...) (int64, error)

Constants

const (
	DockerRegistryURL = "docker.io"
	// RestartTimeout in seconds
	RestartTimeout = 5
	// StopTimeout in seconds
	StopTimeout = 5
	// RetryCount is the amount of retries for Docker operations
	RetryCount = 3
	// WaitTimeout in seconds
	WaitTimeout = 300
	// WaitTimeoutContextKey name
	WaitTimeoutContextKey = "wait_timeout"
)

Functions

func CreateContainer

func CreateContainer(ctx context.Context, dClient *client.Client, hostname string, containerName string, imageCfg *container.Config, hostCfg *container.HostConfig) (container.ContainerCreateCreatedBody, error)

func DoCopyToContainer

func DoCopyToContainer(ctx context.Context, dClient *client.Client, plane, containerName, hostname, destinationDir string, tarFile io.Reader) error

func DoRemoveContainer

func DoRemoveContainer(ctx context.Context, dClient *client.Client, containerName, hostname string) error

func DoRestartContainer

func DoRestartContainer(ctx context.Context, dClient *client.Client, containerName, hostname string) error

func DoRollingUpdateContainer

func DoRollingUpdateContainer(ctx context.Context, dClient *client.Client, imageCfg *container.Config, hostCfg *container.HostConfig, containerName, hostname, plane string, prsMap map[string]v3.PrivateRegistry) error

func DoRunContainer

func DoRunContainer(ctx context.Context, dClient *client.Client, imageCfg *container.Config, hostCfg *container.HostConfig,
	containerName string, hostname string, plane string, prsMap map[string]v3.PrivateRegistry) error

func DoRunOnetimeContainer

func DoRunOnetimeContainer(ctx context.Context, dClient *client.Client, imageCfg *container.Config, hostCfg *container.HostConfig, containerName string, hostname string, plane string, prsMap map[string]v3.PrivateRegistry) error

func DoesContainerExist

func DoesContainerExist(ctx context.Context, dClient *client.Client, hostname string, containerName string, all bool) (bool, error)

func FindContainer

func FindContainer(ctx context.Context, dClient *client.Client, hostname string, containerName string, all bool) (*types.Container, error)

func GetContainerLogsStdoutStderr

func GetContainerLogsStdoutStderr(ctx context.Context, dClient *client.Client, containerName, tail string, follow bool) (string, string, error)

func GetContainerOutput

func GetContainerOutput(ctx context.Context, dClient *client.Client, containerName, hostname string, noisy bool) (int64, string, string, error)

func GetImageRegistryConfig

func GetImageRegistryConfig(image string, prsMap map[string]v3.PrivateRegistry) (string, string, error)

func GetKubeletDockerConfig

func GetKubeletDockerConfig(prsMap map[string]v3.PrivateRegistry) (string, error)

func InspectContainer

func InspectContainer(ctx context.Context, dClient *client.Client, hostname string, containerName string) (types.ContainerJSON, error)

func IsContainerRunning

func IsContainerRunning(ctx context.Context, dClient *client.Client, hostname string, containerName string, all bool) (bool, error)

func IsContainerUpgradable

func IsContainerUpgradable(ctx context.Context, dClient *client.Client, imageCfg *container.Config, hostCfg *container.HostConfig, containerName string, hostname string, plane string) (bool, error)

func IsSupportedDockerVersion

func IsSupportedDockerVersion(info types.Info, K8sVersion string) (bool, error)

func ReadContainerLogs

func ReadContainerLogs(ctx context.Context, dClient *client.Client, containerName string, follow bool, tail string) (io.ReadCloser, error)

func ReadFileFromContainer

func ReadFileFromContainer(ctx context.Context, dClient *client.Client, hostname, container, filePath string) (string, error)

func RemoveContainer

func RemoveContainer(ctx context.Context, dClient *client.Client, hostname string, containerName string) error

func RenameContainer

func RenameContainer(ctx context.Context, dClient *client.Client, hostname string, oldContainerName string, newContainerName string) error

func RestartContainer

func RestartContainer(ctx context.Context, dClient *client.Client, hostname, containerName string) error

func StartContainer

func StartContainer(ctx context.Context, dClient *client.Client, hostname string, containerName string) error

func StopContainer

func StopContainer(ctx context.Context, dClient *client.Client, hostname string, containerName string) error

func StopRenameContainer

func StopRenameContainer(ctx context.Context, dClient *client.Client, hostname string, oldContainerName string, newContainerName string) error

func UseLocalOrPull

func UseLocalOrPull(ctx context.Context, dClient *client.Client, hostname string, containerImage string, plane string,
	prsMap map[string]v3.PrivateRegistry) error

func WaitForContainer

func WaitForContainer(ctx context.Context, dClient *client.Client, hostname string, containerName string, noisy bool) (int64, error)