container

Jul 7, 2015

Changes in this version

type Pod

+ func (p *Pod) ToAPIPod() *api.Pod

Jun 26, 2015

Changes in this version

type Pod

+ func (p *Pod) IsEmpty() bool

May 29, 2015

Changes in this version

+ func EnvVarsToMap(envs []EnvVar) map[string]string

+ func ExpandContainerCommandAndArgs(container *api.Container, envs []EnvVar) (command []string, args []string)

+ func HashContainer(container *api.Container) uint64

+ type EnvVar struct

+ Name string

+ Value string

type FakeRuntime

+ ImageList []Image

+ PodList []*Pod

+ 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) IsImagePresent(image ImageSpec) (bool, 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) RunInContainer(containerID string, cmd []string) ([]byte, error)

+ type FakeVersion struct

+ Version string

+ func (fv *FakeVersion) Compare(other string) (int, error)

+ func (fv *FakeVersion) String() string

+ type Mount struct

+ ContainerPath string

+ HostPath string

+ Name string

+ ReadOnly bool

+ type PortMapping struct

+ ContainerPort int

+ HostIP string

+ HostPort int

+ Name string

+ Protocol api.Protocol

type RunContainerOptions

+ Mounts []Mount

+ PortMappings []PortMapping

May 12, 2015

Changes in this version

+ 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 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 FakeRuntime

+ func (f *FakeRuntime) SyncPod(pod *api.Pod, _ Pod, _ api.PodStatus) error

+ type Image struct

+ ID string

+ Size int64

+ Tags []string

+ type ImageSpec struct

+ Image string

type RunContainerOptions

+ CgroupParent string

type Runtime

+ GetContainerLogs func(pod *api.Pod, containerID, tail string, follow bool, stdout, stderr io.Writer) (err error)

+ ListImages func() ([]Image, error)

+ PullImage func(image ImageSpec, secrets []api.Secret) error

+ RemoveImage func(image ImageSpec) error

+ SyncPod func(pod *api.Pod, runningPod Pod, podStatus api.PodStatus) 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 VolumeMap map[string]volume.Volume

Apr 29, 2015

Changes in this version

+ func TrimRuntimePrefixFromImage(img string) string

+ 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 FakeOS struct

+ func (FakeOS) Mkdir(path string, perm os.FileMode) error

+ func (FakeOS) Symlink(oldname string, newname string) error

+ type HandlerRunner interface

+ Run func(containerID string, pod *api.Pod, container *api.Container, ...) error

+ type OSInterface interface

+ Mkdir func(path string, perm os.FileMode) error

+ Symlink func(oldname string, newname string) error

+ type Prober interface

+ Probe func(pod *api.Pod, status api.PodStatus, container api.Container, ...) (probe.Result, error)

+ type RealOS struct

+ func (RealOS) Mkdir(path string, perm os.FileMode) error

+ func (RealOS) Symlink(oldname string, newname string) error

+ type RunContainerOptionsGenerator interface

+ GenerateRunContainerOptions func(pod *api.Pod, container *api.Container, netMode, ipcMode string) (*RunContainerOptions, error)

type Runtime

+ ExecInContainer func(container api.Container, pod *api.Pod, stdin io.Reader, ...)

+ IsImagePresent func(image string) (bool, error)

+ PortForward func(pod Pod, port uint16, stream io.ReadWriteCloser)

+ Pull func(image string)

+ RunInContainer func(container api.Container, pod *api.Pod, cmd []string)

+ type Version interface

+ Compare func(other string) (int, error)

+ String func() string

Mar 30, 2015

Changes in this version

+ func BuildPodFullName(name, namespace string) string

+ func GetPodFullName(pod *api.Pod) string

+ func ParsePodFullName(podFullName string) (string, string, error)

+ type Container struct

+ Created int64

+ Hash uint64

+ ID types.UID

+ Image string

+ Name string

+ type FakeRuntime struct

+ CalledFunctions []string

+ ContainerList []*Container

+ Err error

+ KilledContainers []string

+ KilledPods []string

+ PodStatus api.PodStatus

+ Podlist []*Pod

+ StartedContainers []string

+ StartedPods []string

+ VersionInfo map[string]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) GetContainers(all bool) ([]*Container, error)

+ func (f *FakeRuntime) GetPodStatus(pod *Pod) (api.PodStatus, error)

+ func (f *FakeRuntime) GetPods(all bool) ([]*Pod, error)

+ func (f *FakeRuntime) KillContainerInPod(container api.Container, pod *api.Pod) error

+ func (f *FakeRuntime) KillPod(pod *api.Pod) error

+ func (f *FakeRuntime) RunContainerInPod(container api.Container, pod *api.Pod, ...) error

+ func (f *FakeRuntime) RunPod(pod *api.Pod, volumeMap map[string]volume.VolumePlugin) error

+ func (f *FakeRuntime) Version() (map[string]string, error)

+ type FakeRuntimeCache struct

+ func (f *FakeRuntimeCache) ForceUpdateIfOlder(time.Time) error

+ func (f *FakeRuntimeCache) GetPods() ([]*Pod, 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) FindPodByID(podUID types.UID) Pod

+ 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 RefManager struct

+ func NewRefManager() *RefManager

+ func (c *RefManager) ClearRef(id string)

+ func (c *RefManager) GenerateContainerRef(pod *api.Pod, container *api.Container) (*api.ObjectReference, error)

+ func (c *RefManager) GetRef(id string) (ref *api.ObjectReference, ok bool)

+ func (c *RefManager) SetRef(id string, ref *api.ObjectReference)

+ type RunContainerOptions struct

+ Binds []string

+ DNS []string

+ DNSSearch []string

+ Envs []string

+ IpcMode string

+ NetMode string

+ PodContainerDir string

+ type Runtime interface

+ GetContainers func(all bool) ([]*Container, error)

+ GetPodStatus func(*Pod) (api.PodStatus, error)

+ GetPods func(all bool) ([]*Pod, error)

+ KillContainerInPod func(api.Container, *api.Pod) error

+ KillPod func(*api.Pod) error

+ RunContainerInPod func(api.Container, *api.Pod, map[string]volume.Volume) error

+ RunPod func(*api.Pod, map[string]volume.Volume) error

+ Version func() (map[string]string, error)

+ type RuntimeCache interface

+ ForceUpdateIfOlder func(time.Time) error

+ GetPods func() ([]*Pod, error)

+ func NewFakeRuntimeCache(runtime Runtime) RuntimeCache

+ func NewRuntimeCache(runtime Runtime) (RuntimeCache, error)