container

package

Go to main page

Versions in this module

v0

v0.4.0

Jun 23, 2016

Changes in this version

+ var ErrKillContainer = errors.New("KillContainerError")

+ var ErrSetupNetwork = errors.New("SetupNetworkError")

+ var ErrTeardownNetwork = errors.New("TeardownNetworkError")

+ var ErrVerifyNonRoot = errors.New("VerifyNonRootError")

+ type Cache interface

+ Delete func(types.UID)

+ Get func(types.UID) (*PodStatus, error)

+ GetNewerThan func(types.UID, time.Time) (*PodStatus, error)

+ Set func(types.UID, *PodStatus, error, time.Time)

+ UpdateTime func(time.Time)

+ func NewCache() Cache

+ type Option func(Runtime)

type Pod

+ func (p *Pod) FindContainerByID(id ContainerID) *Container

+ type PodPair struct

+ APIPod *api.Pod

+ RunningPod *Pod

+ type PodSyncResult struct

+ SyncError error

+ SyncResults []*SyncResult

+ func (p *PodSyncResult) AddPodSyncResult(result PodSyncResult)

+ func (p *PodSyncResult) AddSyncResult(result ...*SyncResult)

+ func (p *PodSyncResult) Error() error

+ func (p *PodSyncResult) Fail(err error)

type RunContainerOptions

+ Hostname string

+ ReadOnly bool

type Runtime

+ APIVersion func() (Version, error)

+ Status func() error

+ type RuntimeHelper interface

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

+ GetClusterDNS func(pod *api.Pod) (dnsServers []string, dnsSearches []string, err error)

+ type SortContainerStatusesByCreationTime []*ContainerStatus

+ func (s SortContainerStatusesByCreationTime) Len() int

+ func (s SortContainerStatusesByCreationTime) Less(i, j int) bool

+ func (s SortContainerStatusesByCreationTime) Swap(i, j int)

+ type SyncAction string

+ const KillContainer

+ const SetupNetwork

+ const StartContainer

+ const TeardownNetwork

+ type SyncResult struct

+ Action SyncAction

+ Error error

+ Message string

+ Target interface{}

+ func NewSyncResult(action SyncAction, target interface{}) *SyncResult

+ func (r *SyncResult) Fail(err error, msg string)

v0.3.0

Mar 16, 2016

Changes in this version

+ const BackOffPullImage

+ const BackOffStartContainer

+ const ContainerUnhealthy

+ const CreatedContainer

+ const ErrImageNeverPullPolicy

+ const FailedMountVolume

+ const FailedSync

+ const FailedToCreateContainer

+ const FailedToInspectImage

+ const FailedToPullImage

+ const FailedToStartContainer

+ const FailedValidation

+ const FreeDiskSpaceFailed

+ const HostNetworkNotSupported

+ const HostPortConflict

+ const InsufficientFreeCPU

+ const InsufficientFreeMemory

+ const InvalidDiskCapacity

+ const KillingContainer

+ const KubeletSetupFailed

+ const NodeNotReady

+ const NodeNotSchedulable

+ const NodeReady

+ const NodeRebooted

+ const NodeSchedulable

+ const NodeSelectorMismatching

+ const OutOfDisk

+ const PulledImage

+ const PullingImage

+ const StartedContainer

+ const StartingKubelet

+ const UndefinedShaper

+ var ErrContainerNotFound = errors.New("no matching container")

+ var ErrImageInspect = errors.New("ImageInspectError")

+ var ErrImageNeverPull = errors.New("ErrImageNeverPull")

+ var ErrImagePull = errors.New("ErrImagePull")

+ var ErrImagePullBackOff = errors.New("ImagePullBackOff")

+ var ErrRunContainer = errors.New("RunContainerError")

+ var ImplicitContainerPrefix string = "implicitly required container "

+ var RegistryUnavailable = errors.New("RegistryUnavailable")

+ func FilterEventRecorder(recorder record.EventRecorder) record.EventRecorder

+ func ShouldContainerBeRestartedOldVersion(container *api.Container, pod *api.Pod, podStatus *api.PodStatus) bool

type Container

+ State ContainerState

+ type ContainerGC interface

+ GarbageCollect func() error

+ func NewContainerGC(runtime Runtime, policy ContainerGCPolicy) (ContainerGC, error)

+ type ContainerGCPolicy struct

+ MaxContainers int

+ MaxPerPodContainer int

+ MinAge time.Duration

+ type ContainerState string

+ const ContainerStateExited

+ const ContainerStateRunning

+ const ContainerStateUnknown

+ type ContainerStatus struct

+ CreatedAt time.Time

+ ExitCode int

+ FinishedAt time.Time

+ Hash uint64

+ ID ContainerID

+ Image string

+ ImageID string

+ Message string

+ Name string

+ Reason string

+ RestartCount int

+ StartedAt time.Time

+ State ContainerState

+ type DockerID string

+ func (id DockerID) ContainerID() ContainerID

type FakeRuntime

+ APIPodStatus api.PodStatus

+ AllPodList []*Pod

+ InspectErr error

+ RuntimeType string

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

+ func (f *FakeRuntime) GarbageCollect(gcPolicy ContainerGCPolicy) error

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

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

+ func (f *FakeRuntime) Type() string

type Image

+ RepoTags []string

type ImagePuller

+ func NewSerializedImagePuller(recorder record.EventRecorder, runtime Runtime, imageBackOff *util.Backoff) ImagePuller

+ type Mock struct

+ func (r *Mock) AttachContainer(containerID ContainerID, stdin io.Reader, stdout, stderr io.WriteCloser, ...) error

+ func (r *Mock) ConvertPodStatusToAPIPodStatus(pod *api.Pod, podStatus *PodStatus) (*api.PodStatus, error)

+ func (r *Mock) ExecInContainer(containerID ContainerID, cmd []string, stdin io.Reader, ...) error

+ func (r *Mock) GarbageCollect(gcPolicy ContainerGCPolicy) error

+ func (r *Mock) GetAPIPodStatus(pod *api.Pod) (*api.PodStatus, error)

+ func (r *Mock) GetContainerLogs(pod *api.Pod, containerID ContainerID, logOptions *api.PodLogOptions, ...) (err error)

+ func (r *Mock) GetPodStatus(uid types.UID, name, namespace string) (*PodStatus, error)

+ func (r *Mock) GetPodStatusAndAPIPodStatus(pod *api.Pod) (*PodStatus, *api.PodStatus, error)

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

+ func (r *Mock) IsImagePresent(image ImageSpec) (bool, error)

+ func (r *Mock) KillContainerInPod(container api.Container, pod *api.Pod) error

+ func (r *Mock) KillPod(pod *api.Pod, runningPod Pod) error

+ func (r *Mock) ListImages() ([]Image, error)

+ func (r *Mock) PortForward(pod *Pod, port uint16, stream io.ReadWriteCloser) error

+ func (r *Mock) PullImage(image ImageSpec, pullSecrets []api.Secret) error

+ func (r *Mock) RemoveImage(image ImageSpec) error

+ func (r *Mock) RunContainerInPod(container api.Container, pod *api.Pod, ...) error

+ func (r *Mock) RunInContainer(containerID ContainerID, cmd []string) ([]byte, error)

+ func (r *Mock) Start() error

+ func (r *Mock) SyncPod(pod *api.Pod, apiStatus api.PodStatus, status *PodStatus, secrets []api.Secret, ...) error

+ func (r *Mock) Type() string

+ func (r *Mock) Version() (Version, error)

type Mount

+ SELinuxRelabel bool

type Pod

+ func ConvertPodStatusToRunningPod(podStatus *PodStatus) Pod

+ type PodStatus struct

+ ContainerStatuses []*ContainerStatus

+ ID types.UID

+ IP string

+ Name string

+ Namespace string

+ func (podStatus *PodStatus) FindContainerStatusByName(containerName string) *ContainerStatus

+ func (podStatus *PodStatus) GetRunningContainerStatuses() []*ContainerStatus

type Runtime

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

+ GarbageCollect func(gcPolicy ContainerGCPolicy) error

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

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

+ Type func() string

+ type VolumeInfo struct

+ Builder volume.Builder

+ SELinuxLabeled bool

v0.1.0

Oct 25, 2015

Changes in this version

+ var ErrCrashLoopBackOff = errors.New("CrashLoopBackOff")

+ 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

+ type Container struct

+ Created int64

+ Hash uint64

+ ID ContainerID

+ Image string

+ Name string

+ type ContainerAttacher interface

+ AttachContainer func(id ContainerID, stdin io.Reader, stdout, stderr io.WriteCloser, tty bool) (err error)

+ type ContainerCommandRunner interface

+ ExecInContainer func(containerID ContainerID, cmd []string, stdin io.Reader, ...) error

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

+ RunInContainer func(containerID ContainerID, cmd []string) ([]byte, error)

+ type ContainerID struct

+ ID string

+ Type string

+ func BuildContainerID(typ, ID string) ContainerID

+ func ParseContainerID(containerID string) ContainerID

+ func (c *ContainerID) IsEmpty() bool

+ 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

+ 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) AttachContainer(containerID ContainerID, stdin io.Reader, stdout, stderr io.WriteCloser, ...) error

+ func (f *FakeRuntime) ClearCalls()

+ func (f *FakeRuntime) ExecInContainer(containerID ContainerID, cmd []string, stdin io.Reader, ...) error

+ func (f *FakeRuntime) GetContainerLogs(pod *api.Pod, containerID ContainerID, logOptions *api.PodLogOptions, ...) (err 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 *api.Pod, runningPod Pod) error

+ func (f *FakeRuntime) ListImages() ([]Image, error)

+ func (f *FakeRuntime) Name() string

+ 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 ContainerID, cmd []string) ([]byte, error)

+ func (f *FakeRuntime) SyncPod(pod *api.Pod, _ Pod, _ api.PodStatus, _ []api.Secret, backOff *util.Backoff) 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 ContainerID, pod *api.Pod, container *api.Container, ...) error

+ type Image struct

+ ID string

+ Size int64

+ Tags []string

+ type ImagePuller interface

+ PullImage func(pod *api.Pod, container *api.Container, pullSecrets []api.Secret) error

+ func NewImagePuller(recorder record.EventRecorder, runtime Runtime) ImagePuller

+ 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

+ func (p *Pod) FindContainerByName(containerName string) *Container

+ func (p *Pod) IsEmpty() bool

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

+ 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 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 ContainerID)

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

+ func (c *RefManager) SetRef(id ContainerID, 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 ContainerID, logOptions *api.PodLogOptions, ...) (err error)

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

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

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

+ KillPod func(pod *api.Pod, runningPod Pod) error

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

+ Name func() string

+ 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 Version interface

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

+ String func() string

+ type VolumeMap map[string]volume.Volume

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