Versions in this module Expand all Collapse all v0 v0.19.0 Jun 9, 2015 Changes in this version + func BuildPodFullName(name, namespace string) string + func EnvVarsToMap(envs []EnvVar) map[string]string + func ExpandContainerCommandAndArgs(container *api.Container, envs []EnvVar) (command []string, args []string) + func GenerateContainerRef(pod *api.Pod, container *api.Container) (*api.ObjectReference, error) + func GetPodFullName(pod *api.Pod) string + func HashContainer(container *api.Container) uint64 + func ParsePodFullName(podFullName string) (string, string, error) + func ShouldContainerBeRestarted(container *api.Container, pod *api.Pod, podStatus *api.PodStatus, ...) bool + func StartPty(c *exec.Cmd) (*os.File, error) — linux/amd64 + func StartPty(c *exec.Cmd) (pty *os.File, err error) — darwin/amd64, js/wasm, windows/amd64 + func TrimRuntimePrefix(fullString string) string + type Container struct + Created int64 + Hash uint64 + ID types.UID + Image string + Name string + type ContainerCommandRunner interface + ExecInContainer func(containerID string, cmd []string, stdin io.Reader, ...) error + PortForward func(pod *Pod, port uint16, stream io.ReadWriteCloser) error + RunInContainer func(containerID string, cmd []string) ([]byte, error) + type ContainerID struct + ID string + Type string + func BuildContainerID(typ, ID string) ContainerID + func (c *ContainerID) MarshalJSON() ([]byte, error) + func (c *ContainerID) ParseString(data string) error + func (c *ContainerID) String() string + func (c *ContainerID) UnmarshalJSON(data []byte) error + type EnvVar struct + Name string + Value string + type FakeOS struct + func (FakeOS) Mkdir(path string, perm os.FileMode) error + func (FakeOS) Symlink(oldname string, newname string) error + type FakeRuntime struct + CalledFunctions []string + ContainerList []*Container + Err error + ImageList []Image + KilledContainers []string + KilledPods []string + PodList []*Pod + PodStatus api.PodStatus + StartedContainers []string + StartedPods []string + VersionInfo string + func (f *FakeRuntime) AssertCalls(calls []string) error + func (f *FakeRuntime) AssertKilledContainers(containers []string) error + func (f *FakeRuntime) AssertKilledPods(pods []string) error + func (f *FakeRuntime) AssertStartedContainers(containers []string) error + func (f *FakeRuntime) AssertStartedPods(pods []string) error + func (f *FakeRuntime) ClearCalls() + func (f *FakeRuntime) ExecInContainer(containerID string, cmd []string, stdin io.Reader, ...) error + func (f *FakeRuntime) GetContainerLogs(pod *api.Pod, containerID, tail string, follow bool, stdout, stderr io.Writer) (err error) + func (f *FakeRuntime) GetContainers(all bool) ([]*Container, error) + func (f *FakeRuntime) GetPodStatus(*api.Pod) (*api.PodStatus, error) + func (f *FakeRuntime) GetPods(all bool) ([]*Pod, error) + func (f *FakeRuntime) IsImagePresent(image ImageSpec) (bool, error) + func (f *FakeRuntime) KillContainerInPod(container api.Container, pod *api.Pod) error + func (f *FakeRuntime) KillPod(pod Pod) error + func (f *FakeRuntime) ListImages() ([]Image, error) + func (f *FakeRuntime) PortForward(pod *Pod, port uint16, stream io.ReadWriteCloser) error + func (f *FakeRuntime) PullImage(image ImageSpec, pullSecrets []api.Secret) error + func (f *FakeRuntime) RemoveImage(image ImageSpec) error + func (f *FakeRuntime) RunContainerInPod(container api.Container, pod *api.Pod, ...) error + func (f *FakeRuntime) RunInContainer(containerID string, cmd []string) ([]byte, error) + func (f *FakeRuntime) SyncPod(pod *api.Pod, _ Pod, _ api.PodStatus, _ []api.Secret) error + func (f *FakeRuntime) Version() (Version, error) + type FakeRuntimeCache struct + func (f *FakeRuntimeCache) ForceUpdateIfOlder(time.Time) error + func (f *FakeRuntimeCache) GetPods() ([]*Pod, error) + type FakeVersion struct + Version string + func (fv *FakeVersion) Compare(other string) (int, error) + func (fv *FakeVersion) String() string + type HandlerRunner interface + Run func(containerID string, pod *api.Pod, container *api.Container, ...) error + type Image struct + ID string + Size int64 + Tags []string + type ImageSpec struct + Image string + type Mount struct + ContainerPath string + HostPath string + Name string + ReadOnly bool + type OSInterface interface + Mkdir func(path string, perm os.FileMode) error + Symlink func(oldname string, newname string) error + type Pod struct + Containers []*Container + ID types.UID + Name string + Namespace string + Status api.PodStatus + func (p *Pod) FindContainerByName(containerName string) *Container + type Pods []*Pod + func (p Pods) FindPod(podFullName string, podUID types.UID) Pod + func (p Pods) FindPodByFullName(podFullName string) Pod + func (p Pods) FindPodByID(podUID types.UID) Pod + type PortMapping struct + ContainerPort int + HostIP string + HostPort int + Name string + Protocol api.Protocol + type ReadinessManager struct + func NewReadinessManager() *ReadinessManager + func (r *ReadinessManager) GetReadiness(id string) bool + func (r *ReadinessManager) RemoveReadiness(id string) + func (r *ReadinessManager) SetReadiness(id string, value bool) + type RealOS struct + func (RealOS) Mkdir(path string, perm os.FileMode) error + func (RealOS) Symlink(oldname string, newname string) error + type RefManager struct + func NewRefManager() *RefManager + func (c *RefManager) ClearRef(id string) + func (c *RefManager) GetRef(id string) (ref *api.ObjectReference, ok bool) + func (c *RefManager) SetRef(id string, ref *api.ObjectReference) + type RunContainerOptions struct + CgroupParent string + DNS []string + DNSSearch []string + Envs []EnvVar + Mounts []Mount + PodContainerDir string + PortMappings []PortMapping + type RunContainerOptionsGenerator interface + GenerateRunContainerOptions func(pod *api.Pod, container *api.Container) (*RunContainerOptions, error) + type Runtime interface + GetContainerLogs func(pod *api.Pod, containerID, tail string, follow bool, stdout, stderr io.Writer) (err error) + GetPodStatus func(*api.Pod) (*api.PodStatus, error) + GetPods func(all bool) ([]*Pod, error) + IsImagePresent func(image ImageSpec) (bool, error) + KillPod func(pod Pod) error + ListImages func() ([]Image, error) + PullImage func(image ImageSpec, pullSecrets []api.Secret) error + RemoveImage func(image ImageSpec) error + SyncPod func(pod *api.Pod, runningPod Pod, podStatus api.PodStatus, ...) error + Version func() (Version, error) + type RuntimeCache interface + ForceUpdateIfOlder func(time.Time) error + GetPods func() ([]*Pod, error) + func NewFakeRuntimeCache(getter podsGetter) RuntimeCache + func NewRuntimeCache(getter podsGetter) (RuntimeCache, error) + type RuntimeHooks interface + ReportImagePull func(pod *api.Pod, container *api.Container, err error) + ShouldPullImage func(pod *api.Pod, container *api.Container, imagePresent bool) bool + type Version interface + Compare func(other string) (int, error) + String func() string + type VolumeMap map[string]volume.Volume