docker

package

v0.0.0-...-f45d039 Latest Latest Go to latest Published: Mar 23, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/zdnscloud/zke

Documentation ¶

Index ¶

Constants
Variables
func CreateContainer(ctx context.Context, dClient *client.Client, hostname string, ...) (container.ContainerCreateCreatedBody, 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 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]types.PrivateRegistry) (string, string, error)
func GetKubeletDockerConfig(prsMap map[string]types.PrivateRegistry) (string, error)
func InspectContainer(ctx context.Context, dClient *client.Client, hostname string, ...) (dockertypes.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 dockertypes.Info, K8sVersion string) (bool, error)
func LoadImage(ctx context.Context, dClient *client.Client, hostname, filePath string) 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 ¶

View Source

const (
	DockerRegistryURL = "docker.io"
	// RestartTimeout in seconds
	RestartTimeout = 5
	// StopTimeout in seconds
	StopTimeout = 5
)

Variables ¶

View Source

var K8sDockerVersions = map[string][]string{
	"1.17": {"1.13.x", "17.03.x", "17.06.x", "17.09.x", "18.06.x", "18.09.x", "19.03.x"},
}

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 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]types.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]types.PrivateRegistry) 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) (int64, string, string, error)

func GetImageRegistryConfig ¶

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

func GetKubeletDockerConfig ¶

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

func InspectContainer ¶

func InspectContainer(ctx context.Context, dClient *client.Client, hostname string, containerName string) (dockertypes.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 dockertypes.Info, K8sVersion string) (bool, error)

func LoadImage ¶

func LoadImage(ctx context.Context, dClient *client.Client, hostname, filePath string) 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]types.PrivateRegistry) error

func WaitForContainer ¶

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

Types ¶

This section is empty.

Source Files ¶

View all Source files

docker.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL