Versions in this module Expand all Collapse all v0 v0.19.0 Jun 9, 2015 Changes in this version + const DockerPrefix + const PodInfraContainerImage + const PodInfraContainerName + var ErrContainerCannotRun = errors.New("Container cannot run") + var ErrNoContainersInPod = errors.New("no containers exist for this pod") + var ErrNoPodInfraContainerInPod = errors.New("No pod infra container exists for this pod") + func BuildDockerName(dockerName KubeletContainerName, container *api.Container) string + func NewVersion(input string) (dockerVersion, error) + type DockerContainers map[kubeletTypes.DockerID]*docker.APIContainers + func GetKubeletDockerContainers(client DockerInterface, allContainers bool) (DockerContainers, error) + func (c DockerContainers) FindPodContainer(podFullName string, uid types.UID, containerName string) (*docker.APIContainers, bool, uint64) + type DockerInterface interface + CreateContainer func(docker.CreateContainerOptions) (*docker.Container, error) + CreateExec func(docker.CreateExecOptions) (*docker.Exec, error) + Info func() (*docker.Env, error) + InspectContainer func(id string) (*docker.Container, error) + InspectExec func(id string) (*docker.ExecInspect, 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) + func ConnectToDockerOrDie(dockerEndpoint string) DockerInterface + func NewInstrumentedDockerInterface(dockerClient DockerInterface) DockerInterface + type DockerManager struct + func NewDockerManager(client DockerInterface, recorder record.EventRecorder, ...) *DockerManager + func NewFakeDockerManager(client DockerInterface, recorder record.EventRecorder, ...) *DockerManager + func (dm *DockerManager) ExecInContainer(containerId string, cmd []string, stdin io.Reader, ...) error + func (dm *DockerManager) GetContainerLogs(pod *api.Pod, containerID, tail string, follow bool, stdout, stderr io.Writer) (err error) + func (dm *DockerManager) GetContainers(all bool) ([]*kubecontainer.Container, error) + func (dm *DockerManager) GetPodInfraContainer(pod kubecontainer.Pod) (kubecontainer.Container, error) + func (dm *DockerManager) GetPodStatus(pod *api.Pod) (*api.PodStatus, error) + func (dm *DockerManager) GetPods(all bool) ([]*kubecontainer.Pod, error) + func (dm *DockerManager) IsImagePresent(image kubecontainer.ImageSpec) (bool, error) + func (dm *DockerManager) KillContainer(containerID types.UID) error + func (dm *DockerManager) KillContainerInPod(container api.Container, pod *api.Pod) error + func (dm *DockerManager) KillPod(pod kubecontainer.Pod) error + func (dm *DockerManager) ListImages() ([]kubecontainer.Image, error) + func (dm *DockerManager) PortForward(pod *kubecontainer.Pod, port uint16, stream io.ReadWriteCloser) error + func (dm *DockerManager) PullImage(image kubecontainer.ImageSpec, secrets []api.Secret) error + func (dm *DockerManager) RemoveImage(image kubecontainer.ImageSpec) error + func (dm *DockerManager) RunInContainer(containerID string, cmd []string) ([]byte, error) + func (dm *DockerManager) SyncPod(pod *api.Pod, runningPod kubecontainer.Pod, podStatus api.PodStatus, ...) error + func (dm *DockerManager) Version() (kubecontainer.Version, error) + type DockerPuller interface + IsImagePresent func(image string) (bool, error) + Pull func(image string, secrets []api.Secret) error + type ExecHandler interface + ExecInContainer func(client DockerInterface, container *docker.Container, cmd []string, ...) error + type FakeDockerClient struct + Container *docker.Container + ContainerList []docker.APIContainers + ContainerMap map[string]*docker.Container + Created []string + Errors map[string]error + ExecInspect *docker.ExecInspect + ExitedContainerList []docker.APIContainers + Image *docker.Image + Images []docker.APIImages + Information docker.Env + Removed []string + RemovedImages util.StringSet + Stopped []string + VersionInfo docker.Env + func (f *FakeDockerClient) AssertCalls(calls []string) (err error) + func (f *FakeDockerClient) AssertCreated(created []string) error + func (f *FakeDockerClient) AssertStopped(stopped []string) error + func (f *FakeDockerClient) AssertUnorderedCalls(calls []string) (err error) + func (f *FakeDockerClient) ClearCalls() + func (f *FakeDockerClient) CreateContainer(c docker.CreateContainerOptions) (*docker.Container, error) + func (f *FakeDockerClient) CreateExec(opts docker.CreateExecOptions) (*docker.Exec, error) + func (f *FakeDockerClient) Info() (*docker.Env, error) + func (f *FakeDockerClient) InspectContainer(id string) (*docker.Container, error) + func (f *FakeDockerClient) InspectExec(id string) (*docker.ExecInspect, 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, secrets []api.Secret) (err error) + type KubeletContainerName struct + ContainerName string + PodFullName string + PodUID types.UID + func ParseDockerName(name string) (dockerName *KubeletContainerName, hash uint64, err error) + type NativeExecHandler struct + func (*NativeExecHandler) ExecInContainer(client DockerInterface, container *docker.Container, cmd []string, ...) error + type NsenterExecHandler struct + func (*NsenterExecHandler) ExecInContainer(client DockerInterface, container *docker.Container, cmd []string, ...) error + type PodContainerChangesSpec struct + ContainersToKeep map[kubeletTypes.DockerID]int + ContainersToStart map[int]empty + InfraContainerId kubeletTypes.DockerID + StartInfraContainer bool
Go to main page