Versions in this module Expand all Collapse all v1 v1.24.10 Oct 24, 2017 v1.24.9 Oct 24, 2017 Changes in this version + const FakeHost + func NewFakeCache(runtime container.Runtime) container.Cache + func NewFakeRuntimeCache(getter podsGetter) RuntimeCache + type FakeContainerCommandRunner struct + Cmd []string + ContainerID ContainerID + Err error + Stdout string + func (f *FakeContainerCommandRunner) RunInContainer(containerID ContainerID, cmd []string, timeout time.Duration) ([]byte, error) + type FakeDirectStreamingRuntime struct + Args struct{ ... } + func (f *FakeDirectStreamingRuntime) AttachContainer(containerID ContainerID, stdin io.Reader, stdout, stderr io.WriteCloser, ...) error + func (f *FakeDirectStreamingRuntime) ExecInContainer(containerID ContainerID, cmd []string, stdin io.Reader, ...) error + func (f *FakeDirectStreamingRuntime) PortForward(pod *Pod, port int32, stream io.ReadWriteCloser) error + type FakeIndirectStreamingRuntime struct + func (f *FakeIndirectStreamingRuntime) GetAttach(id ContainerID, stdin, stdout, stderr, tty bool) (*url.URL, error) + func (f *FakeIndirectStreamingRuntime) GetExec(id ContainerID, cmd []string, stdin, stdout, stderr, tty bool) (*url.URL, error) + func (f *FakeIndirectStreamingRuntime) GetPortForward(podName, podNamespace string, podUID types.UID, ports []int32) (*url.URL, error) + type FakeOS struct + Files map[string][]*os.FileInfo + HostName string + MkdirAllFn func(string, os.FileMode) error + ReadDirFn func(string) ([]os.FileInfo, error) + Removes []string + StatFn func(string) (os.FileInfo, error) + SymlinkFn func(string, string) error + func NewFakeOS() *FakeOS + func (FakeOS) Chmod(path string, perm os.FileMode) error + func (FakeOS) Chtimes(path string, atime time.Time, mtime time.Time) error + func (FakeOS) Create(path string) (*os.File, error) + func (FakeOS) Pipe() (r *os.File, w *os.File, err error) + func (f *FakeOS) Glob(pattern string) ([]string, error) + func (f *FakeOS) Hostname() (name string, err error) + func (f *FakeOS) MkdirAll(path string, perm os.FileMode) error + func (f *FakeOS) ReadDir(dirname string) ([]os.FileInfo, error) + func (f *FakeOS) Remove(path string) error + func (f *FakeOS) RemoveAll(path string) error + func (f *FakeOS) Symlink(oldname string, newname string) error + func (f FakeOS) Stat(path string) (os.FileInfo, error) + type FakePod struct + NetnsPath string + Pod *Pod + type FakeRuntime struct + APIPodStatus v1.PodStatus + APIVersionInfo string + AllPodList []*FakePod + CalledFunctions []string + Err error + ImageList []Image + InspectErr error + KilledContainers []string + KilledPods []string + PodList []*FakePod + PodStatus PodStatus + RuntimeStatus *RuntimeStatus + RuntimeType string + StartedContainers []string + StartedPods []string + StatusErr error + VersionInfo string + func (f *FakeRuntime) APIVersion() (Version, error) + 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) DeleteContainer(containerID ContainerID) error + func (f *FakeRuntime) GarbageCollect(gcPolicy ContainerGCPolicy, ready bool, evictNonDeletedPods bool) error + func (f *FakeRuntime) GetContainerLogs(pod *v1.Pod, containerID ContainerID, logOptions *v1.PodLogOptions, ...) (err error) + func (f *FakeRuntime) GetImageRef(image ImageSpec) (string, error) + func (f *FakeRuntime) GetNetNS(containerID ContainerID) (string, error) + func (f *FakeRuntime) GetPodContainerID(pod *Pod) (ContainerID, error) + func (f *FakeRuntime) GetPodStatus(uid types.UID, name, namespace string) (*PodStatus, error) + func (f *FakeRuntime) GetPods(all bool) ([]*Pod, error) + func (f *FakeRuntime) ImageStats() (*ImageStats, error) + func (f *FakeRuntime) KillContainerInPod(container v1.Container, pod *v1.Pod) error + func (f *FakeRuntime) KillPod(pod *v1.Pod, runningPod Pod, gracePeriodOverride *int64) error + func (f *FakeRuntime) ListImages() ([]Image, error) + func (f *FakeRuntime) PullImage(image ImageSpec, pullSecrets []v1.Secret) (string, error) + func (f *FakeRuntime) RemoveImage(image ImageSpec) error + func (f *FakeRuntime) RunContainerInPod(container v1.Container, pod *v1.Pod, volumeMap map[string]volume.VolumePlugin) error + func (f *FakeRuntime) Status() (*RuntimeStatus, error) + func (f *FakeRuntime) SyncPod(pod *v1.Pod, _ v1.PodStatus, _ *PodStatus, _ []v1.Secret, ...) (result PodSyncResult) + func (f *FakeRuntime) Type() string + func (f *FakeRuntime) UpdatePodCIDR(c string) error + func (f *FakeRuntime) Version() (Version, error) + type FakeRuntimeCache struct + func (f *FakeRuntimeCache) ForceUpdateIfOlder(time.Time) error + func (f *FakeRuntimeCache) GetPods() ([]*Pod, error) + type FakeRuntimeHelper struct + DNSSearches []string + DNSServers []string + Err error + HostDomain string + HostName string + PodContainerDir string + func (f *FakeRuntimeHelper) GeneratePodHostNameAndDomain(pod *v1.Pod) (string, string, error) + func (f *FakeRuntimeHelper) GenerateRunContainerOptions(pod *v1.Pod, container *v1.Container, podIP string) (*kubecontainer.RunContainerOptions, bool, error) + func (f *FakeRuntimeHelper) GetClusterDNS(pod *v1.Pod) ([]string, []string, bool, error) + func (f *FakeRuntimeHelper) GetExtraSupplementalGroupsForPod(pod *v1.Pod) []int64 + func (f *FakeRuntimeHelper) GetPodCgroupParent(pod *v1.Pod) string + func (f *FakeRuntimeHelper) GetPodDir(podUID kubetypes.UID) string + type FakeVersion struct + Version string + func (fv *FakeVersion) Compare(other string) (int, error) + func (fv *FakeVersion) String() string + type Mock struct + func (r *Mock) APIVersion() (Version, error) + func (r *Mock) AttachContainer(containerID ContainerID, stdin io.Reader, stdout, stderr io.WriteCloser, ...) error + func (r *Mock) DeleteContainer(containerID ContainerID) error + func (r *Mock) ExecInContainer(containerID ContainerID, cmd []string, stdin io.Reader, ...) error + func (r *Mock) GarbageCollect(gcPolicy ContainerGCPolicy, ready bool, evictNonDeletedPods bool) error + func (r *Mock) GetContainerLogs(pod *v1.Pod, containerID ContainerID, logOptions *v1.PodLogOptions, ...) (err error) + func (r *Mock) GetImageRef(image ImageSpec) (string, error) + func (r *Mock) GetNetNS(containerID ContainerID) (string, error) + func (r *Mock) GetPodContainerID(pod *Pod) (ContainerID, error) + func (r *Mock) GetPodStatus(uid types.UID, name, namespace string) (*PodStatus, error) + func (r *Mock) GetPods(all bool) ([]*Pod, error) + func (r *Mock) ImageStats() (*ImageStats, error) + func (r *Mock) KillContainerInPod(container v1.Container, pod *v1.Pod) error + func (r *Mock) KillPod(pod *v1.Pod, runningPod Pod, gracePeriodOverride *int64) 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 []v1.Secret) (string, error) + func (r *Mock) RemoveImage(image ImageSpec) error + func (r *Mock) RunContainerInPod(container v1.Container, pod *v1.Pod, volumeMap map[string]volume.VolumePlugin) error + func (r *Mock) Start() error + func (r *Mock) Status() (*RuntimeStatus, error) + func (r *Mock) SyncPod(pod *v1.Pod, apiStatus v1.PodStatus, status *PodStatus, secrets []v1.Secret, ...) PodSyncResult + func (r *Mock) Type() string + func (r *Mock) UpdatePodCIDR(c string) error + func (r *Mock) Version() (Version, error) + type MockFileInfo struct + func NewMockFileInfo(ctrl *gomock.Controller) *MockFileInfo + func (_m *MockFileInfo) EXPECT() *_MockFileInfoRecorder + func (_m *MockFileInfo) IsDir() bool + func (_m *MockFileInfo) ModTime() time.Time + func (_m *MockFileInfo) Mode() os.FileMode + func (_m *MockFileInfo) Name() string + func (_m *MockFileInfo) Size() int64 + func (_m *MockFileInfo) Sys() interface{} + type MockRuntimeCache struct + func (_m *MockRuntimeCache) ForceUpdateIfOlder(_a0 time.Time) error + func (_m *MockRuntimeCache) GetPods() ([]*container.Pod, error)