Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + const FakeHost + func NewFakeCache(runtime container.Runtime) container.Cache + func NewFakeRuntimeCache(getter podsGetter) kubecontainer.RuntimeCache + type FakeContainerCommandRunner struct + Cmd []string + ContainerID kubecontainer.ContainerID + Err error + Stdout string + func (f *FakeContainerCommandRunner) RunInContainer(containerID kubecontainer.ContainerID, cmd []string, timeout time.Duration) ([]byte, 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 *kubecontainer.Pod + type FakeRuntime struct + APIPodStatus v1.PodStatus + APIVersionInfo string + AllPodList []*FakePod + CalledFunctions []string + Err error + ImageList []kubecontainer.Image + InspectErr error + KilledContainers []string + KilledPods []string + PodList []*FakePod + PodStatus kubecontainer.PodStatus + RuntimeStatus *kubecontainer.RuntimeStatus + RuntimeType string + StartedContainers []string + StartedPods []string + StatusErr error + VersionInfo string + func (f *FakeRuntime) APIVersion() (kubecontainer.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 kubecontainer.ContainerID) error + func (f *FakeRuntime) GarbageCollect(gcPolicy kubecontainer.ContainerGCPolicy, ready bool, evictNonDeletedPods bool) error + func (f *FakeRuntime) GetContainerLogs(_ context.Context, pod *v1.Pod, containerID kubecontainer.ContainerID, ...) (err error) + func (f *FakeRuntime) GetImageRef(image kubecontainer.ImageSpec) (string, error) + func (f *FakeRuntime) GetPodStatus(uid types.UID, name, namespace string) (*kubecontainer.PodStatus, error) + func (f *FakeRuntime) GetPods(all bool) ([]*kubecontainer.Pod, error) + func (f *FakeRuntime) ImageStats() (*kubecontainer.ImageStats, error) + func (f *FakeRuntime) KillContainerInPod(container v1.Container, pod *v1.Pod) error + func (f *FakeRuntime) KillPod(pod *v1.Pod, runningPod kubecontainer.Pod, gracePeriodOverride *int64) error + func (f *FakeRuntime) ListImages() ([]kubecontainer.Image, error) + func (f *FakeRuntime) PullImage(image kubecontainer.ImageSpec, pullSecrets []v1.Secret, ...) (string, error) + func (f *FakeRuntime) RemoveImage(image kubecontainer.ImageSpec) error + func (f *FakeRuntime) RunContainerInPod(container v1.Container, pod *v1.Pod, volumeMap map[string]volume.VolumePlugin) error + func (f *FakeRuntime) Status() (*kubecontainer.RuntimeStatus, error) + func (f *FakeRuntime) SyncPod(pod *v1.Pod, _ *kubecontainer.PodStatus, _ []v1.Secret, ...) (result kubecontainer.PodSyncResult) + func (f *FakeRuntime) Type() string + func (f *FakeRuntime) UpdatePodCIDR(c string) error + func (f *FakeRuntime) Version() (kubecontainer.Version, error) + type FakeRuntimeCache struct + func (f *FakeRuntimeCache) ForceUpdateIfOlder(time.Time) error + func (f *FakeRuntimeCache) GetPods() ([]*kubecontainer.Pod, error) + type FakeRuntimeHelper struct + DNSOptions []string + 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, func(), error) + func (f *FakeRuntimeHelper) GetExtraSupplementalGroupsForPod(pod *v1.Pod) []int64 + func (f *FakeRuntimeHelper) GetPodCgroupParent(pod *v1.Pod) string + func (f *FakeRuntimeHelper) GetPodDNS(pod *v1.Pod) (*runtimeapi.DNSConfig, error) + func (f *FakeRuntimeHelper) GetPodDir(podUID kubetypes.UID) string + type FakeStreamingRuntime struct + func (f *FakeStreamingRuntime) GetAttach(id kubecontainer.ContainerID, stdin, stdout, stderr, tty bool) (*url.URL, error) + func (f *FakeStreamingRuntime) GetExec(id kubecontainer.ContainerID, cmd []string, stdin, stdout, stderr, tty bool) (*url.URL, error) + func (f *FakeStreamingRuntime) GetPortForward(podName, podNamespace string, podUID types.UID, ports []int32) (*url.URL, error) + 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() (kubecontainer.Version, error) + func (r *Mock) AttachContainer(containerID kubecontainer.ContainerID, stdin io.Reader, ...) error + func (r *Mock) DeleteContainer(containerID kubecontainer.ContainerID) error + func (r *Mock) ExecInContainer(containerID kubecontainer.ContainerID, cmd []string, stdin io.Reader, ...) error + func (r *Mock) GarbageCollect(gcPolicy kubecontainer.ContainerGCPolicy, ready bool, evictNonDeletedPods bool) error + func (r *Mock) GetContainerLogs(_ context.Context, pod *v1.Pod, containerID kubecontainer.ContainerID, ...) (err error) + func (r *Mock) GetImageRef(image kubecontainer.ImageSpec) (string, error) + func (r *Mock) GetPodStatus(uid types.UID, name, namespace string) (*kubecontainer.PodStatus, error) + func (r *Mock) GetPods(all bool) ([]*kubecontainer.Pod, error) + func (r *Mock) ImageStats() (*kubecontainer.ImageStats, error) + func (r *Mock) KillContainerInPod(container v1.Container, pod *v1.Pod) error + func (r *Mock) KillPod(pod *v1.Pod, runningPod kubecontainer.Pod, gracePeriodOverride *int64) error + func (r *Mock) ListImages() ([]kubecontainer.Image, error) + func (r *Mock) PortForward(pod *kubecontainer.Pod, port uint16, stream io.ReadWriteCloser) error + func (r *Mock) PullImage(image kubecontainer.ImageSpec, pullSecrets []v1.Secret, ...) (string, error) + func (r *Mock) RemoveImage(image kubecontainer.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() (*kubecontainer.RuntimeStatus, error) + func (r *Mock) SyncPod(pod *v1.Pod, status *kubecontainer.PodStatus, secrets []v1.Secret, ...) kubecontainer.PodSyncResult + func (r *Mock) Type() string + func (r *Mock) UpdatePodCIDR(c string) error + func (r *Mock) Version() (kubecontainer.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)
Go to main page