container

package
v0.11.1-0...-a229925 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 24, 2015 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// Container event reason list
	CreatedContainer        = "Created"
	StartedContainer        = "Started"
	FailedToCreateContainer = "Failed"
	FailedToStartContainer  = "Failed"
	KillingContainer        = "Killing"
	BackOffStartContainer   = "BackOff"

	// Image event reason list
	PullingImage            = "Pulling"
	PulledImage             = "Pulled"
	FailedToPullImage       = "Failed"
	FailedToInspectImage    = "InspectFailed"
	ErrImageNeverPullPolicy = "ErrImageNeverPull"
	BackOffPullImage        = "BackOff"

	// kubelet event reason list
	NodeReady               = "NodeReady"
	NodeNotReady            = "NodeNotReady"
	NodeSchedulable         = "NodeSchedulable"
	NodeNotSchedulable      = "NodeNotSchedulable"
	StartingKubelet         = "Starting"
	KubeletSetupFailed      = "KubeletSetupFailed"
	FailedMountVolume       = "FailedMount"
	HostPortConflict        = "HostPortConflict"
	NodeSelectorMismatching = "NodeSelectorMismatching"
	InsufficientFreeCPU     = "InsufficientFreeCPU"
	InsufficientFreeMemory  = "InsufficientFreeMemory"
	OutOfDisk               = "OutOfDisk"
	HostNetworkNotSupported = "HostNetworkNotSupported"
	UndefinedShaper         = "NilShaper"
	NodeRebooted            = "Rebooted"

	// Image manager event reason list
	InvalidDiskCapacity = "InvalidDiskCapacity"
	FreeDiskSpaceFailed = "FreeDiskSpaceFailed"

	// Probe event reason list
	ContainerUnhealthy = "Unhealthy"

	// Pod worker event reason list
	FailedSync = "FailedSync"

	// Config event reason list
	FailedValidation = "FailedValidation"
)

Variables

View Source
var (
	// Container image pull failed, kubelet is backing off image pull
	ErrImagePullBackOff = errors.New("ImagePullBackOff")

	// Unable to inspect image
	ErrImageInspect = errors.New("ImageInspectError")

	// General image pull error
	ErrImagePull = errors.New("ErrImagePull")

	// Required Image is absent on host and PullPolicy is NeverPullImage
	ErrImageNeverPull = errors.New("ErrImageNeverPull")

	// Get http error when pulling image from registry
	RegistryUnavailable = errors.New("RegistryUnavailable")
)
View Source
var ErrCrashLoopBackOff = errors.New("CrashLoopBackOff")

Container Terminated and Kubelet is backing off the restart

View Source
var ErrRunContainer = errors.New("RunContainerError")
View Source
var ImplicitContainerPrefix string = "implicitly required container "

Functions

func BuildPodFullName

func BuildPodFullName(name, namespace string) string

Build the pod full name from pod name and namespace.

func EnvVarsToMap

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

EnvVarsToMap constructs a map of environment name to value from a slice of env vars.

func ExpandContainerCommandAndArgs

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

func FilterEventRecorder

func FilterEventRecorder(recorder record.EventRecorder) record.EventRecorder

Create an event recorder to record object's event except implicitly required container's, like infra container.

func GenerateContainerRef

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

GenerateContainerRef returns an *api.ObjectReference which references the given container within the given pod. Returns an error if the reference can't be constructed or the container doesn't actually belong to the pod.

This function will return an error if the provided Pod does not have a selfLink, but we expect selfLink to be populated at all call sites for the function.

func GetPodFullName

func GetPodFullName(pod *api.Pod) string

GetPodFullName returns a name that uniquely identifies a pod.

func HashContainer

func HashContainer(container *api.Container) uint64

HashContainer returns the hash of the container. It is used to compare the running container with its desired spec.

func ParsePodFullName

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

Parse the pod full name.

func ShouldContainerBeRestarted

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

ShouldContainerBeRestarted checks whether a container needs to be restarted. TODO(yifan): Think about how to refactor this.

func StartPty

func StartPty(c *exec.Cmd) (*os.File, error)

Types

type Container

type Container struct {
	// The ID of the container, used by the container runtime to identify
	// a container.
	ID ContainerID
	// The name of the container, which should be the same as specified by
	// api.Container.
	Name string
	// The image name of the container.
	Image string
	// Hash of the container, used for comparison. Optional for containers
	// not managed by kubelet.
	Hash uint64
	// The timestamp of the creation time of the container.
	// TODO(yifan): Consider to move it to api.ContainerStatus.
	Created int64
	// Status is the status of the container.
	Status ContainerStatus
}

Container provides the runtime information for a container, such as ID, hash, status of the container.

type ContainerAttacher

type ContainerAttacher interface {
	AttachContainer(id ContainerID, stdin io.Reader, stdout, stderr io.WriteCloser, tty bool) (err error)
}

type ContainerCommandRunner

type ContainerCommandRunner interface {
	// TODO(vmarmol): Merge RunInContainer and ExecInContainer.
	// Runs the command in the container of the specified pod using nsinit.
	RunInContainer(containerID ContainerID, cmd []string) ([]byte, error)
	// Runs the command in the container of the specified pod using nsenter.
	// Attaches the processes stdin, stdout, and stderr. Optionally uses a
	// tty.
	ExecInContainer(containerID ContainerID, cmd []string, stdin io.Reader, stdout, stderr io.WriteCloser, tty bool) error
	// Forward the specified port from the specified pod to the stream.
	PortForward(pod *Pod, port uint16, stream io.ReadWriteCloser) error
}

CommandRunner encapsulates the command runner interfaces for testability.

type ContainerGC

type ContainerGC interface {
	// Garbage collect containers.
	GarbageCollect() error
}

Manages garbage collection of dead containers.

Implementation is thread-compatible.

func NewContainerGC

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

New ContainerGC instance with the specified policy.

type ContainerGCPolicy

type ContainerGCPolicy struct {
	// Minimum age at which a container can be garbage collected, zero for no limit.
	MinAge time.Duration

	// Max number of dead containers any single pod (UID, container name) pair is
	// allowed to have, less than zero for no limit.
	MaxPerPodContainer int

	// Max number of total dead containers, less than zero for no limit.
	MaxContainers int
}

Specified a policy for garbage collecting containers.

type ContainerID

type ContainerID struct {
	// The type of the container runtime. e.g. 'docker', 'rkt'.
	Type string
	// The identification of the container, this is comsumable by
	// the underlying container runtime. (Note that the container
	// runtime interface still takes the whole struct as input).
	ID string
}

ContainerID is a type that identifies a container.

func BuildContainerID

func BuildContainerID(typ, ID string) ContainerID

func ParseContainerID

func ParseContainerID(containerID string) ContainerID

Convenience method for creating a ContainerID from an ID string.

func (*ContainerID) IsEmpty

func (c *ContainerID) IsEmpty() bool

func (*ContainerID) MarshalJSON

func (c *ContainerID) MarshalJSON() ([]byte, error)

func (*ContainerID) ParseString

func (c *ContainerID) ParseString(data string) error

func (*ContainerID) String

func (c *ContainerID) String() string

func (*ContainerID) UnmarshalJSON

func (c *ContainerID) UnmarshalJSON(data []byte) error

type ContainerStatus

type ContainerStatus string
const (
	ContainerStatusRunning ContainerStatus = "running"
	ContainerStatusExited  ContainerStatus = "exited"
	// This unknown encompasses all the statuses that we currently don't care.
	ContainerStatusUnknown ContainerStatus = "unknown"
)

type EnvVar

type EnvVar struct {
	Name  string
	Value string
}

type FakeOS

type FakeOS struct{}

FakeOS mocks out certain OS calls to avoid perturbing the filesystem on the test machine.

func (FakeOS) Mkdir

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

MkDir is a fake call that just returns nil.

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

Symlink is a fake call that just returns nil.

type FakeRuntime

type FakeRuntime struct {
	sync.Mutex
	CalledFunctions   []string
	PodList           []*Pod
	AllPodList        []*Pod
	ImageList         []Image
	PodStatus         api.PodStatus
	RawPodStatus      RawPodStatus
	StartedPods       []string
	KilledPods        []string
	StartedContainers []string
	KilledContainers  []string
	VersionInfo       string
	RuntimeType       string
	Err               error
	InspectErr        error
}

FakeRuntime is a fake container runtime for testing.

func (*FakeRuntime) AssertCalls

func (f *FakeRuntime) AssertCalls(calls []string) error

AssertCalls test if the invoked functions are as expected.

func (*FakeRuntime) AssertKilledContainers

func (f *FakeRuntime) AssertKilledContainers(containers []string) error

func (*FakeRuntime) AssertKilledPods

func (f *FakeRuntime) AssertKilledPods(pods []string) error

func (*FakeRuntime) AssertStartedContainers

func (f *FakeRuntime) AssertStartedContainers(containers []string) error

func (*FakeRuntime) AssertStartedPods

func (f *FakeRuntime) AssertStartedPods(pods []string) error

func (*FakeRuntime) AttachContainer

func (f *FakeRuntime) AttachContainer(containerID ContainerID, stdin io.Reader, stdout, stderr io.WriteCloser, tty bool) error

func (*FakeRuntime) ClearCalls

func (f *FakeRuntime) ClearCalls()

ClearCalls resets the FakeRuntime to the initial state.

func (*FakeRuntime) ConvertRawToPodStatus

func (f *FakeRuntime) ConvertRawToPodStatus(_ *api.Pod, _ *RawPodStatus) (*api.PodStatus, error)

func (*FakeRuntime) ExecInContainer

func (f *FakeRuntime) ExecInContainer(containerID ContainerID, cmd []string, stdin io.Reader, stdout, stderr io.WriteCloser, tty bool) error

func (*FakeRuntime) GarbageCollect

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

func (*FakeRuntime) GetContainerLogs

func (f *FakeRuntime) GetContainerLogs(pod *api.Pod, containerID ContainerID, logOptions *api.PodLogOptions, stdout, stderr io.Writer) (err error)

func (*FakeRuntime) GetPodStatus

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

func (*FakeRuntime) GetPods

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

func (*FakeRuntime) GetRawPodStatus

func (f *FakeRuntime) GetRawPodStatus(uid types.UID, name, namespace string) (*RawPodStatus, error)

func (*FakeRuntime) IsImagePresent

func (f *FakeRuntime) IsImagePresent(image ImageSpec) (bool, error)

func (*FakeRuntime) KillContainerInPod

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

func (*FakeRuntime) KillPod

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

func (*FakeRuntime) ListImages

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

func (*FakeRuntime) PortForward

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

func (*FakeRuntime) PullImage

func (f *FakeRuntime) PullImage(image ImageSpec, pullSecrets []api.Secret) error

func (*FakeRuntime) RemoveImage

func (f *FakeRuntime) RemoveImage(image ImageSpec) error

func (*FakeRuntime) RunContainerInPod

func (f *FakeRuntime) RunContainerInPod(container api.Container, pod *api.Pod, volumeMap map[string]volume.VolumePlugin) error

func (*FakeRuntime) RunInContainer

func (f *FakeRuntime) RunInContainer(containerID ContainerID, cmd []string) ([]byte, error)

func (*FakeRuntime) SyncPod

func (f *FakeRuntime) SyncPod(pod *api.Pod, _ Pod, _ api.PodStatus, _ []api.Secret, backOff *util.Backoff) error

func (*FakeRuntime) Type

func (f *FakeRuntime) Type() string

func (*FakeRuntime) Version

func (f *FakeRuntime) Version() (Version, error)

type FakeRuntimeCache

type FakeRuntimeCache struct {
	// contains filtered or unexported fields
}

func (*FakeRuntimeCache) ForceUpdateIfOlder

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

func (*FakeRuntimeCache) GetPods

func (f *FakeRuntimeCache) GetPods() ([]*Pod, error)

type FakeVersion

type FakeVersion struct {
	Version string
}

func (*FakeVersion) Compare

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

func (*FakeVersion) String

func (fv *FakeVersion) String() string

type HandlerRunner

type HandlerRunner interface {
	Run(containerID ContainerID, pod *api.Pod, container *api.Container, handler *api.Handler) error
}

HandlerRunner runs a lifecycle handler for a container.

type Image

type Image struct {
	// ID of the image.
	ID string
	// Other names by which this image is known.
	Tags []string
	// The size of the image in bytes.
	Size int64
}

Basic information about a container image.

type ImagePuller

type ImagePuller interface {
	PullImage(pod *api.Pod, container *api.Container, pullSecrets []api.Secret) (error, string)
}

ImagePuller wraps Runtime.PullImage() to pull a container image. It will check the presence of the image, and report the 'image pulling', 'image pulled' events correspondingly.

func NewImagePuller

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

NewImagePuller takes an event recorder and container runtime to create a image puller that wraps the container runtime's PullImage interface.

func NewSerializedImagePuller

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

NewSerializedImagePuller takes an event recorder and container runtime to create a image puller that wraps the container runtime's PullImage interface. Pulls one image at a time. Issue #10959 has the rationale behind serializing image pulls.

type ImageSpec

type ImageSpec struct {
	Image string
}

ImageSpec is an internal representation of an image. Currently, it wraps the value of a Container's Image field, but in the future it will include more detailed information about the different image types.

type Mount

type Mount struct {
	// Name of the volume mount.
	Name string
	// Path of the mount within the container.
	ContainerPath string
	// Path of the mount on the host.
	HostPath string
	// Whether the mount is read-only.
	ReadOnly bool
	// Whether the mount needs SELinux relabeling
	SELinuxRelabel bool
}

type OSInterface

type OSInterface interface {
	Mkdir(path string, perm os.FileMode) error
	Symlink(oldname string, newname string) error
}

OSInterface collects system level operations that need to be mocked out during tests.

type Pod

type Pod struct {
	// The ID of the pod, which can be used to retrieve a particular pod
	// from the pod list returned by GetPods().
	ID types.UID
	// The name and namespace of the pod, which is readable by human.
	Name      string
	Namespace string
	// List of containers that belongs to this pod. It may contain only
	// running containers, or mixed with dead ones (when GetPods(true)).
	Containers []*Container
}

Pod is a group of containers.

func (*Pod) FindContainerByName

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

FindContainerByName returns a container in the pod with the given name. When there are multiple containers with the same name, the first match will be returned.

func (*Pod) IsEmpty

func (p *Pod) IsEmpty() bool

IsEmpty returns true if the pod is empty.

func (*Pod) ToAPIPod

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

ToAPIPod converts Pod to api.Pod. Note that if a field in api.Pod has no corresponding field in Pod, the field would not be populated.

type Pods

type Pods []*Pod

func (Pods) FindPod

func (p Pods) FindPod(podFullName string, podUID types.UID) Pod

FindPod combines FindPodByID and FindPodByFullName, it finds and returns a pod in the pod list either by the full name or the pod ID. It will return an empty pod if not found.

func (Pods) FindPodByFullName

func (p Pods) FindPodByFullName(podFullName string) Pod

FindPodByFullName finds and returns a pod in the pod list by the full name. It will return an empty pod if not found.

func (Pods) FindPodByID

func (p Pods) FindPodByID(podUID types.UID) Pod

FindPodByID finds and returns a pod in the pod list by UID. It will return an empty pod if not found.

type PortMapping

type PortMapping struct {
	// Name of the port mapping
	Name string
	// Protocol of the port mapping.
	Protocol api.Protocol
	// The port number within the container.
	ContainerPort int
	// The port number on the host.
	HostPort int
	// The host IP.
	HostIP string
}

type RawContainerStatus

type RawContainerStatus struct {
	// ID of the container.
	ID ContainerID
	// Name of the container.
	Name string
	// Status of the container.
	Status ContainerStatus
	// Creation time of the container.
	CreatedAt time.Time
	// Start time of the container.
	StartedAt time.Time
	// Finish time of the container.
	FinishedAt time.Time
	// Exit code of the container.
	ExitCode int
	// Name of the image.
	Image string
	// ID of the image.
	ImageID string
	// Hash of the container, used for comparison.
	Hash string
	// Number of times that the container has been restarted.
	RestartCount int
	// A string explains why container is in such a status.
	Reason string
	// Message written by the container before exiting (stored in
	// TerminationMessagePath).
	Message string
}

RawPodContainer represents the status of a container.

type RawPodStatus

type RawPodStatus struct {
	// ID of the pod.
	ID types.UID
	// Name of the pod.
	Name string
	// Namspace of the pod.
	Namespace string
	// IP of the pod.
	IP string
	// Status of containers in the pod.
	ContainerStatuses []*RawContainerStatus
}

RawPodStatus represents the status of the pod and its containers. api.PodStatus can be derived from examining RawPodStatus and api.Pod.

type RealOS

type RealOS struct{}

RealOS is used to dispatch the real system level operaitons.

func (RealOS) Mkdir

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

MkDir will will call os.Mkdir to create a directory.

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

Symlink will call os.Symlink to create a symbolic link.

type RefManager

type RefManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

RefManager manages the references for the containers. The references are used for reporting events such as creation, failure, etc. This manager is thread-safe, no locks are necessary for the caller.

func NewRefManager

func NewRefManager() *RefManager

NewRefManager creates and returns a container reference manager with empty contents.

func (*RefManager) ClearRef

func (c *RefManager) ClearRef(id ContainerID)

ClearRef forgets the given container id and its associated container reference.

func (*RefManager) GetRef

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

GetRef returns the container reference of the given ID, or (nil, false) if none is stored.

func (*RefManager) SetRef

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

SetRef stores a reference to a pod's container, associating it with the given container ID.

type RunContainerOptions

type RunContainerOptions struct {
	// The environment variables list.
	Envs []EnvVar
	// The mounts for the containers.
	Mounts []Mount
	// The port mappings for the containers.
	PortMappings []PortMapping
	// If the container has specified the TerminationMessagePath, then
	// this directory will be used to create and mount the log file to
	// container.TerminationMessagePath
	PodContainerDir string
	// The list of DNS servers for the container to use.
	DNS []string
	// The list of DNS search domains.
	DNSSearch []string
	// The parent cgroup to pass to Docker
	CgroupParent string
}

RunContainerOptions specify the options which are necessary for running containers

type RunContainerOptionsGenerator

type RunContainerOptionsGenerator interface {
	GenerateRunContainerOptions(pod *api.Pod, container *api.Container) (*RunContainerOptions, error)
}

RunContainerOptionsGenerator generates the options that necessary for container runtime to run a container.

type Runtime

type Runtime interface {
	// Type returns the type of the container runtime.
	Type() string

	// Version returns the version information of the container runtime.
	Version() (Version, error)
	// GetPods returns a list containers group by pods. The boolean parameter
	// specifies whether the runtime returns all containers including those already
	// exited and dead containers (used for garbage collection).
	GetPods(all bool) ([]*Pod, error)
	// GarbageCollect removes dead containers using the specified container gc policy
	GarbageCollect(gcPolicy ContainerGCPolicy) error
	// Syncs the running pod into the desired pod.
	SyncPod(pod *api.Pod, runningPod Pod, podStatus api.PodStatus, pullSecrets []api.Secret, backOff *util.Backoff) error
	// KillPod kills all the containers of a pod. Pod may be nil, running pod must not be.
	KillPod(pod *api.Pod, runningPod Pod) error
	// GetPodStatus retrieves the status of the pod, including the information of
	// all containers in the pod. Clients of this interface assume the
	// containers' statuses in a pod always have a deterministic ordering
	// (e.g., sorted by name).
	// TODO: Rename this to GetAPIPodStatus, and eventually deprecate the
	// function in favor of GetRawPodStatus.
	GetPodStatus(*api.Pod) (*api.PodStatus, error)
	// GetRawPodStatus retrieves the status of the pod, including the
	// information of all containers in the pod that are visble in Runtime.
	// TODO: Rename this to GetPodStatus to replace the original function.
	GetRawPodStatus(uid types.UID, name, namespace string) (*RawPodStatus, error)
	// ConvertRawToPodStatus converts the RawPodStatus object to api.PodStatus.
	// This function is needed because Docker generates some high-level and/or
	// pod-level information for api.PodStatus (e.g., check whether the image
	// exists to determine the reason).
	// TODO: Deprecate this function once we generalize the logic for all
	// container runtimes in kubelet.
	ConvertRawToPodStatus(*api.Pod, *RawPodStatus) (*api.PodStatus, error)
	// PullImage pulls an image from the network to local storage using the supplied
	// secrets if necessary.
	PullImage(image ImageSpec, pullSecrets []api.Secret) error
	// IsImagePresent checks whether the container image is already in the local storage.
	IsImagePresent(image ImageSpec) (bool, error)
	// Gets all images currently on the machine.
	ListImages() ([]Image, error)
	// Removes the specified image.
	RemoveImage(image ImageSpec) error
	// TODO(vmarmol): Unify pod and containerID args.
	// GetContainerLogs returns logs of a specific container. By
	// default, it returns a snapshot of the container log. Set 'follow' to true to
	// stream the log. Set 'follow' to false and specify the number of lines (e.g.
	// "100" or "all") to tail the log.
	GetContainerLogs(pod *api.Pod, containerID ContainerID, logOptions *api.PodLogOptions, stdout, stderr io.Writer) (err error)
	// ContainerCommandRunner encapsulates the command runner interfaces for testability.
	ContainerCommandRunner
	// ContainerAttach encapsulates the attaching to containers for testability
	ContainerAttacher
}

Runtime interface defines the interfaces that should be implemented by a container runtime. Thread safety is required from implementations of this interface.

type RuntimeCache

type RuntimeCache interface {
	GetPods() ([]*Pod, error)
	ForceUpdateIfOlder(time.Time) error
}

func NewFakeRuntimeCache

func NewFakeRuntimeCache(getter podsGetter) RuntimeCache

func NewRuntimeCache

func NewRuntimeCache(getter podsGetter) (RuntimeCache, error)

NewRuntimeCache creates a container runtime cache.

type Version

type Version interface {
	// Compare compares two versions of the runtime. On success it returns -1
	// if the version is less than the other, 1 if it is greater than the other,
	// or 0 if they are equal.
	Compare(other string) (int, error)
	// String returns a string that represents the version.
	String() string
}

type VolumeInfo

type VolumeInfo struct {
	// Builder is the volume's builder
	Builder volume.Builder
	// SELinuxLabeled indicates whether this volume has had the
	// pod's SELinux label applied to it or not
	SELinuxLabeled bool
}

VolumeInfo contains information about the volume.

type VolumeMap

type VolumeMap map[string]VolumeInfo

Jump to

Keyboard shortcuts

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