kubernetes: github.com/erimatnor/kubernetes/pkg/kubelet/container Index | Files

package container

import "github.com/erimatnor/kubernetes/pkg/kubelet/container"

Index

Package Files

container_reference_manager.go fake_runtime.go helpers.go os.go readiness_manager.go ref.go runtime.go runtime_cache.go

func BuildPodFullName Uses

func BuildPodFullName(name, namespace string) string

Build the pod full name from pod name and namespace.

func GenerateContainerRef Uses

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 Uses

func GetPodFullName(pod *api.Pod) string

GetPodFullName returns a name that uniquely identifies a pod.

func ParsePodFullName Uses

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

Parse the pod full name.

func ShouldContainerBeRestarted Uses

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

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

func TrimRuntimePrefix Uses

func TrimRuntimePrefix(fullString string) string

Trims runtime prefix from ID or image name (e.g.: docker://busybox -> busybox).

type Container Uses

type Container struct {
    // The ID of the container, used by the container runtime to identify
    // a container.
    ID  types.UID
    // 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
}

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

type ContainerID Uses

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 Uses

func BuildContainerID(typ, ID string) ContainerID

func (*ContainerID) MarshalJSON Uses

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

func (*ContainerID) ParseString Uses

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

func (*ContainerID) String Uses

func (c *ContainerID) String() string

func (*ContainerID) UnmarshalJSON Uses

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

type FakeOS Uses

type FakeOS struct{}

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

func (FakeOS) Mkdir Uses

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 Uses

type FakeRuntime struct {
    sync.Mutex
    CalledFunctions   []string
    Podlist           []*Pod
    ContainerList     []*Container
    PodStatus         api.PodStatus
    StartedPods       []string
    KilledPods        []string
    StartedContainers []string
    KilledContainers  []string
    VersionInfo       map[string]string
    Err               error
}

FakeRuntime is a fake container runtime for testing.

func (*FakeRuntime) AssertCalls Uses

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

AssertCalls test if the invoked functions are as expected.

func (*FakeRuntime) AssertKilledContainers Uses

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

func (*FakeRuntime) AssertKilledPods Uses

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

func (*FakeRuntime) AssertStartedContainers Uses

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

func (*FakeRuntime) AssertStartedPods Uses

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

func (*FakeRuntime) ClearCalls Uses

func (f *FakeRuntime) ClearCalls()

ClearCalls resets the FakeRuntime to the initial state.

func (*FakeRuntime) GetContainers Uses

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

func (*FakeRuntime) GetPodStatus Uses

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

func (*FakeRuntime) GetPods Uses

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

func (*FakeRuntime) KillContainerInPod Uses

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

func (*FakeRuntime) KillPod Uses

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

func (*FakeRuntime) RunContainerInPod Uses

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

func (*FakeRuntime) SyncPod Uses

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

func (*FakeRuntime) Version Uses

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

type FakeRuntimeCache Uses

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

func (*FakeRuntimeCache) ForceUpdateIfOlder Uses

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

func (*FakeRuntimeCache) GetPods Uses

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

type HandlerRunner Uses

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

HandlerRunner runs a lifecycle handler for a container.

type Image Uses

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 OSInterface Uses

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 Uses

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
    // The status of the pod.
    // TODO(yifan): Inspect and get the statuses for all pods can be expensive,
    // maybe we want to get one pod's status at a time (e.g. GetPodStatus()
    // for the particular pod after we GetPods()).
    Status api.PodStatus
}

Pod is a group of containers, with the status of the pod.

func (*Pod) FindContainerByName Uses

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.

type Pods Uses

type Pods []*Pod

func (Pods) FindPod Uses

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 Uses

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 Uses

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 ReadinessManager Uses

type ReadinessManager struct {
    // guards states
    sync.RWMutex
    // contains filtered or unexported fields
}

ReadinessManager maintains the readiness information(probe results) of containers over time to allow for implementation of health thresholds. This manager is thread-safe, no locks are necessary for the caller.

func NewReadinessManager Uses

func NewReadinessManager() *ReadinessManager

NewReadinessManager creates ane returns a readiness manager with empty contents.

func (*ReadinessManager) GetReadiness Uses

func (r *ReadinessManager) GetReadiness(id string) bool

GetReadiness returns the readiness value for the container with the given ID. If the readiness value is found, returns it. If the readiness is not found, returns false.

func (*ReadinessManager) RemoveReadiness Uses

func (r *ReadinessManager) RemoveReadiness(id string)

RemoveReadiness clears the readiness value for the container with the given ID.

func (*ReadinessManager) SetReadiness Uses

func (r *ReadinessManager) SetReadiness(id string, value bool)

SetReadiness sets the readiness value for the container with the given ID.

type RealOS Uses

type RealOS struct{}

RealOS is used to dispatch the real system level operaitons.

func (RealOS) Mkdir Uses

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 Uses

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 Uses

func NewRefManager() *RefManager

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

func (*RefManager) ClearRef Uses

func (c *RefManager) ClearRef(id string)

ClearRef forgets the given container id and its associated container reference. TODO(yifan): This is currently never called. Consider to remove this function, or figure out when to clear the references.

func (*RefManager) GetRef Uses

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

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

func (*RefManager) SetRef Uses

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

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

type RunContainerOptions Uses

type RunContainerOptions struct {
    // The environment variables, they are in the form of 'key=value'.
    Envs []string
    // The mounts for the containers, they are in the form of:
    // 'hostPath:containerPath', or
    // 'hostPath:containerPath:ro', if the path read only.
    Binds []string
    // 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
    // Docker namespace identifiers(currently we have 'NetMode' and 'IpcMode'.
    // These are for docker to attach a container in a pod to the pod infra
    // container's namespace.
    // TODO(yifan): Remove these after we pushed the pod infra container logic
    // into docker's container runtime.
    NetMode string
    IpcMode string
    // The parent cgroup to pass to Docker
    CgroupParent string
}

RunContainerOptions specify the options which are necessary for running containers

type RunContainerOptionsGenerator Uses

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

RunContainerOptionsGenerator generates the options that necessary for container runtime to run a container. TODO(yifan): Remove netMode, ipcMode.

type Runtime Uses

type Runtime interface {
    // 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)
    // Syncs the running pod into the desired pod.
    SyncPod(pod *api.Pod, runningPod Pod, podStatus api.PodStatus) error
    // KillPod kills all the containers of a pod.
    KillPod(pod Pod) error
    // GetPodStatus retrieves the status of the pod, including the information of
    // all containers in the pod.
    GetPodStatus(*api.Pod) (*api.PodStatus, error)
    // TODO(vmarmol): Merge RunInContainer and ExecInContainer.
    // Runs the command in the container of the specified pod using nsinit.
    // TODO(yifan): Use strong type for containerID.
    RunInContainer(containerID string, 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.
    // TODO(yifan): Use strong type for containerID.
    ExecInContainer(containerID string, 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
    // PullImage pulls an image from the network to local storage.
    PullImage(image string) error
    // IsImagePresent checks whether the container image is already in the local storage.
    IsImagePresent(image string) (bool, error)
    // Gets all images currently on the machine.
    ListImages() ([]Image, error)
    // Removes the specified image.
    RemoveImage(image string) 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, tail string, follow bool, stdout, stderr io.Writer) (err error)
}

Runtime interface defines the interfaces that should be implemented by a container runtime.

type RuntimeCache Uses

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

func NewFakeRuntimeCache Uses

func NewFakeRuntimeCache(getter podsGetter) RuntimeCache

func NewRuntimeCache Uses

func NewRuntimeCache(getter podsGetter) (RuntimeCache, error)

NewRuntimeCache creates a container runtime cache.

type RuntimeHooks Uses

type RuntimeHooks interface {
    // Determines whether the runtime should pull the specified container's image.
    ShouldPullImage(pod *api.Pod, container *api.Container, imagePresent bool) bool

    // Runs after an image is pulled reporting its status. Error may be nil
    // for a successful pull.
    ReportImagePull(pod *api.Pod, container *api.Container, err error)
}

Customizable hooks injected into container runtimes.

type Version Uses

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
}

Package container imports 11 packages (graph). Updated 2017-05-11. Refresh now. Tools for package owners.