Versions in this module Expand all Collapse all v0 v0.2.2 Feb 4, 2015 Changes in this version + const PodInfraContainerName + var ErrNoPodInfraContainerInPod = errors.New("No pod infra container exists for this pod") v0.2.1 Jan 28, 2015 Changes in this version + var ErrContainerCannotRun = errors.New("Container cannot run") + var ErrNoContainersInPod = errors.New("no containers exist for this pod") + var ErrNoNetworkContainerInPod = errors.New("No network container exists for this pod") + func BuildDockerName(podUID, podFullName string, container *api.Container) string + func GetDockerPodInfo(client DockerInterface, manifest api.PodSpec, podFullName, uuid string) (api.PodInfo, error) + func GetKubeletDockerContainerLogs(client DockerInterface, containerID, tail string, follow bool, ...) (err error) + func GetRecentDockerContainersWithNameAndUUID(client DockerInterface, podFullName, uuid, containerName string) ([]*docker.Container, error) + func GetUnusedImages(client DockerInterface) ([]string, error) + func HashContainer(container *api.Container) uint64 + func ParseDockerName(name string) (podFullName, podUID, containerName string, hash uint64) + func RequireLatestImage(name string) bool + type ContainerCommandRunner interface + RunInContainer func(containerID string, cmd []string) ([]byte, error) + func NewDockerContainerCommandRunner(client DockerInterface) ContainerCommandRunner + type DockerContainers map[DockerID]*docker.APIContainers + func GetKubeletDockerContainers(client DockerInterface, allContainers bool) (DockerContainers, error) + func (c DockerContainers) FindContainersByPodFullName(podFullName string) map[string]*docker.APIContainers + func (c DockerContainers) FindPodContainer(podFullName, uuid, containerName string) (*docker.APIContainers, bool, uint64) + type DockerID string + type DockerInterface interface + CreateContainer func(docker.CreateContainerOptions) (*docker.Container, error) + CreateExec func(docker.CreateExecOptions) (*docker.Exec, error) + InspectContainer func(id string) (*docker.Container, error) + InspectImage func(image string) (*docker.Image, error) + ListContainers func(options docker.ListContainersOptions) ([]docker.APIContainers, error) + ListImages func(opts docker.ListImagesOptions) ([]docker.APIImages, error) + Logs func(opts docker.LogsOptions) error + PullImage func(opts docker.PullImageOptions, auth docker.AuthConfiguration) error + RemoveContainer func(opts docker.RemoveContainerOptions) error + RemoveImage func(image string) error + StartContainer func(id string, hostConfig *docker.HostConfig) error + StartExec func(string, docker.StartExecOptions) error + StopContainer func(id string, timeout uint) error + Version func() (*docker.Env, error) + type DockerPuller interface + IsImagePresent func(image string) (bool, error) + Pull func(image string) error + func NewDockerPuller(client DockerInterface, qps float32, burst int) DockerPuller + type FakeDockerClient struct + Container *docker.Container + ContainerList []docker.APIContainers + ContainerMap map[string]*docker.Container + Created []string + Err error + Image *docker.Image + Images []docker.APIImages + Removed []string + RemovedImages util.StringSet + Stopped []string + VersionInfo docker.Env + func (f *FakeDockerClient) AssertCalls(calls []string) (err error) + func (f *FakeDockerClient) ClearCalls() + func (f *FakeDockerClient) CreateContainer(c docker.CreateContainerOptions) (*docker.Container, error) + func (f *FakeDockerClient) CreateExec(_ docker.CreateExecOptions) (*docker.Exec, error) + func (f *FakeDockerClient) InspectContainer(id string) (*docker.Container, error) + func (f *FakeDockerClient) InspectImage(name string) (*docker.Image, error) + func (f *FakeDockerClient) ListContainers(options docker.ListContainersOptions) ([]docker.APIContainers, error) + func (f *FakeDockerClient) ListImages(opts docker.ListImagesOptions) ([]docker.APIImages, error) + func (f *FakeDockerClient) Logs(opts docker.LogsOptions) error + func (f *FakeDockerClient) PullImage(opts docker.PullImageOptions, auth docker.AuthConfiguration) error + func (f *FakeDockerClient) RemoveContainer(opts docker.RemoveContainerOptions) error + func (f *FakeDockerClient) RemoveImage(image string) error + func (f *FakeDockerClient) StartContainer(id string, hostConfig *docker.HostConfig) error + func (f *FakeDockerClient) StartExec(_ string, _ docker.StartExecOptions) error + func (f *FakeDockerClient) StopContainer(id string, timeout uint) error + func (f *FakeDockerClient) Version() (*docker.Env, error) + type FakeDockerPuller struct + ErrorsToInject []error + HasImages []string + ImagesPulled []string + func (f *FakeDockerPuller) IsImagePresent(name string) (bool, error) + func (f *FakeDockerPuller) Pull(image string) (err error)