testing

package
v1.22.9-rc.0 Latest Latest
Warning

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

 Go to latest Published: Mar 16, 2022 License: Apache-2.0 Imports: 18 Imported by: 103

Documentation

Overview

Code generated by mockery v1.0.0

Index

Constants

View Source 
const FakeHost = "localhost:12345"

Variables

This section is empty.

Functions

func NewFakeCache 

func NewFakeCache(runtime container.Runtime) container.Cache

func NewFakeRuntimeCache 

func NewFakeRuntimeCache(getter podsGetter) kubecontainer.RuntimeCache

Types

type FakeContainerCommandRunner added in v1.5.0 

type FakeContainerCommandRunner struct {
	// what to return
	Stdout string
	Err    error

	// actual values when invoked
	ContainerID kubecontainer.ContainerID
	Cmd         []string
}

func (*FakeContainerCommandRunner) RunInContainer added in v1.5.0 

func (f *FakeContainerCommandRunner) RunInContainer(containerID kubecontainer.ContainerID, cmd []string, timeout time.Duration) ([]byte, error)

type FakeOS 

type FakeOS struct {
	StatFn     func(string) (os.FileInfo, error)
	ReadDirFn  func(string) ([]os.FileInfo, error)
	MkdirAllFn func(string, os.FileMode) error
	SymlinkFn  func(string, string) error
	GlobFn     func(string, string) bool
	HostName   string
	Removes    []string
	Files      map[string][]*os.FileInfo
}

FakeOS mocks out certain OS calls to avoid perturbing the filesystem If a member of the form `*Fn` is set, that function will be called in place of the real call.

func NewFakeOS added in v1.3.0 

func NewFakeOS() *FakeOS

func (FakeOS) Chmod added in v1.6.0 

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

Chmod is a fake call that returns nil.

func (FakeOS) Chtimes added in v1.3.0 

func (FakeOS) Chtimes(path string, atime time.Time, mtime time.Time) error

Chtimes is a fake call that returns nil.

func (*FakeOS) Create added in v1.3.0 

func (f *FakeOS) Create(path string) (*os.File, error)

Create is a fake call that creates a virtual file and returns nil.

func (*FakeOS) Glob added in v1.5.0 

func (f *FakeOS) Glob(pattern string) ([]string, error)

Glob is a fake call that returns list of virtual files matching a pattern.

func (*FakeOS) Hostname added in v1.3.0 

func (f *FakeOS) Hostname() (name string, err error)

Hostname is a fake call that returns nil.

func (*FakeOS) MkdirAll added in v1.3.0 

func (f *FakeOS) MkdirAll(path string, perm os.FileMode) error

Mkdir is a fake call that just returns nil.

func (FakeOS) Open added in v1.17.12 

func (FakeOS) Open(name string) (*os.File, error)

Open is a fake call that returns nil.

func (FakeOS) OpenFile added in v1.17.12 

func (FakeOS) OpenFile(name string, flag int, perm os.FileMode) (*os.File, error)

OpenFile is a fake call that return nil.

func (FakeOS) Pipe added in v1.3.0 

func (FakeOS) Pipe() (r *os.File, w *os.File, err error)

Pipe is a fake call that returns nil.

func (*FakeOS) ReadDir added in v1.3.0 

func (f *FakeOS) ReadDir(dirname string) ([]os.FileInfo, error)

ReadDir is a fake call that returns the files under the directory.

func (*FakeOS) Remove added in v1.3.0 

func (f *FakeOS) Remove(path string) error

Remove is a fake call that returns nil.

func (*FakeOS) RemoveAll added in v1.5.0 

func (f *FakeOS) RemoveAll(path string) error

RemoveAll is a fake call that just returns nil.

func (FakeOS) Rename added in v1.17.12 

func (FakeOS) Rename(oldpath, newpath string) error

Rename is a fake call that return nil.

func (FakeOS) Stat added in v1.3.0 

func (f FakeOS) Stat(path string) (os.FileInfo, error)

Stat is a fake that returns an error 

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

Symlink is a fake call that just returns nil.

type FakePod added in v1.3.0 

type FakePod struct {
	Pod       *kubecontainer.Pod
	NetnsPath string
}

type FakeRuntime 

type FakeRuntime struct {
	sync.Mutex
	CalledFunctions   []string
	PodList           []*FakePod
	AllPodList        []*FakePod
	ImageList         []kubecontainer.Image
	APIPodStatus      v1.PodStatus
	PodStatus         kubecontainer.PodStatus
	StartedPods       []string
	KilledPods        []string
	StartedContainers []string
	KilledContainers  []string
	RuntimeStatus     *kubecontainer.RuntimeStatus
	VersionInfo       string
	APIVersionInfo    string
	RuntimeType       string
	Err               error
	InspectErr        error
	StatusErr         error
	T                 *testing.T
}

FakeRuntime is a fake container runtime for testing.

func (*FakeRuntime) APIVersion 

func (f *FakeRuntime) APIVersion() (kubecontainer.Version, error)

func (*FakeRuntime) AssertCalls 

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

AssertCalls test if the invoked functions are as expected.

func (*FakeRuntime) AssertKilledContainers 

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

func (*FakeRuntime) AssertKilledPods 

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

func (*FakeRuntime) AssertStartedContainers 

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

func (*FakeRuntime) AssertStartedPods 

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

func (*FakeRuntime) ClearCalls 

func (f *FakeRuntime) ClearCalls()

ClearCalls resets the FakeRuntime to the initial state.

func (*FakeRuntime) DeleteContainer added in v1.4.0 

func (f *FakeRuntime) DeleteContainer(containerID kubecontainer.ContainerID) error

func (*FakeRuntime) GarbageCollect 

func (f *FakeRuntime) GarbageCollect(gcPolicy kubecontainer.GCPolicy, ready bool, evictNonDeletedPods bool) error

func (*FakeRuntime) GetContainerLogs 

func (f *FakeRuntime) GetContainerLogs(_ context.Context, pod *v1.Pod, containerID kubecontainer.ContainerID, logOptions *v1.PodLogOptions, stdout, stderr io.Writer) (err error)

func (*FakeRuntime) GetImageRef added in v1.6.0 

func (f *FakeRuntime) GetImageRef(image kubecontainer.ImageSpec) (string, error)

func (*FakeRuntime) GetPodStatus 

func (f *FakeRuntime) GetPodStatus(uid types.UID, name, namespace string) (*kubecontainer.PodStatus, error)

func (*FakeRuntime) GetPods 

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

func (*FakeRuntime) ImageStats added in v1.3.0 

func (f *FakeRuntime) ImageStats() (*kubecontainer.ImageStats, error)

func (*FakeRuntime) KillContainerInPod 

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

func (*FakeRuntime) KillPod 

func (f *FakeRuntime) KillPod(pod *v1.Pod, runningPod kubecontainer.Pod, gracePeriodOverride *int64) error

func (*FakeRuntime) ListImages 

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

func (*FakeRuntime) PullImage 

func (f *FakeRuntime) PullImage(image kubecontainer.ImageSpec, pullSecrets []v1.Secret, podSandboxConfig *runtimeapi.PodSandboxConfig) (string, error)

func (*FakeRuntime) RemoveImage 

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

func (*FakeRuntime) RunContainerInPod 

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

func (*FakeRuntime) Status 

func (f *FakeRuntime) Status() (*kubecontainer.RuntimeStatus, error)

func (*FakeRuntime) SupportsSingleFileMapping added in v1.17.0 

func (f *FakeRuntime) SupportsSingleFileMapping() bool

func (*FakeRuntime) SyncPod 

func (f *FakeRuntime) SyncPod(pod *v1.Pod, _ *kubecontainer.PodStatus, _ []v1.Secret, backOff *flowcontrol.Backoff) (result kubecontainer.PodSyncResult)

func (*FakeRuntime) Type 

func (f *FakeRuntime) Type() string

func (*FakeRuntime) UpdatePodCIDR added in v1.5.0 

func (f *FakeRuntime) UpdatePodCIDR(c string) error

UpdatePodCIDR fulfills the cri interface.

func (*FakeRuntime) Version 

func (f *FakeRuntime) Version() (kubecontainer.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() ([]*kubecontainer.Pod, error)

type FakeRuntimeHelper added in v1.6.0 

type FakeRuntimeHelper struct {
	DNSServers      []string
	DNSSearches     []string
	DNSOptions      []string
	HostName        string
	HostDomain      string
	PodContainerDir string
	Err             error
}

FakeRuntimeHelper implements RuntimeHelper interfaces for testing purposes.

func (*FakeRuntimeHelper) GeneratePodHostNameAndDomain added in v1.6.0 

func (f *FakeRuntimeHelper) GeneratePodHostNameAndDomain(pod *v1.Pod) (string, string, error)

This is not used by docker runtime.

func (*FakeRuntimeHelper) GenerateRunContainerOptions added in v1.6.0 

func (f *FakeRuntimeHelper) GenerateRunContainerOptions(pod *v1.Pod, container *v1.Container, podIP string, podIPs []string) (*kubecontainer.RunContainerOptions, func(), error)

func (*FakeRuntimeHelper) GetExtraSupplementalGroupsForPod added in v1.6.0 

func (f *FakeRuntimeHelper) GetExtraSupplementalGroupsForPod(pod *v1.Pod) []int64

func (*FakeRuntimeHelper) GetPodCgroupParent added in v1.6.0 

func (f *FakeRuntimeHelper) GetPodCgroupParent(pod *v1.Pod) string

func (*FakeRuntimeHelper) GetPodDNS added in v1.9.0 

func (f *FakeRuntimeHelper) GetPodDNS(pod *v1.Pod) (*runtimeapi.DNSConfig, error)

func (*FakeRuntimeHelper) GetPodDir added in v1.6.0 

func (f *FakeRuntimeHelper) GetPodDir(podUID kubetypes.UID) string

type FakeStreamingRuntime added in v1.11.0 

type FakeStreamingRuntime struct {
	*FakeRuntime
}

func (*FakeStreamingRuntime) GetAttach added in v1.11.0 

func (f *FakeStreamingRuntime) GetAttach(id kubecontainer.ContainerID, stdin, stdout, stderr, tty bool) (*url.URL, error)

func (*FakeStreamingRuntime) GetExec added in v1.11.0 

func (f *FakeStreamingRuntime) GetExec(id kubecontainer.ContainerID, cmd []string, stdin, stdout, stderr, tty bool) (*url.URL, error)

func (*FakeStreamingRuntime) GetPortForward added in v1.11.0 

func (f *FakeStreamingRuntime) GetPortForward(podName, podNamespace string, podUID types.UID, ports []int32) (*url.URL, 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 Mock 

type Mock struct {
	mock.Mock
}

func (*Mock) APIVersion 

func (r *Mock) APIVersion() (kubecontainer.Version, error)

func (*Mock) AttachContainer 

func (r *Mock) AttachContainer(containerID kubecontainer.ContainerID, stdin io.Reader, stdout, stderr io.WriteCloser, tty bool, resize <-chan remotecommand.TerminalSize) error

func (*Mock) DeleteContainer added in v1.4.0 

func (r *Mock) DeleteContainer(containerID kubecontainer.ContainerID) error

func (*Mock) ExecInContainer 

func (r *Mock) ExecInContainer(containerID kubecontainer.ContainerID, cmd []string, stdin io.Reader, stdout, stderr io.WriteCloser, tty bool, resize <-chan remotecommand.TerminalSize, timeout time.Duration) error

func (*Mock) GarbageCollect 

func (r *Mock) GarbageCollect(gcPolicy kubecontainer.GCPolicy, ready bool, evictNonDeletedPods bool) error

func (*Mock) GetContainerLogs 

func (r *Mock) GetContainerLogs(_ context.Context, pod *v1.Pod, containerID kubecontainer.ContainerID, logOptions *v1.PodLogOptions, stdout, stderr io.Writer) (err error)

func (*Mock) GetImageRef added in v1.6.0 

func (r *Mock) GetImageRef(image kubecontainer.ImageSpec) (string, error)

func (*Mock) GetPodStatus 

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

func (*Mock) GetPods 

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

func (*Mock) ImageStats added in v1.3.0 

func (r *Mock) ImageStats() (*kubecontainer.ImageStats, error)

func (*Mock) KillContainerInPod 

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

func (*Mock) KillPod 

func (r *Mock) KillPod(pod *v1.Pod, runningPod kubecontainer.Pod, gracePeriodOverride *int64) error

func (*Mock) ListImages 

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

func (*Mock) PortForward 

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

func (*Mock) PullImage 

func (r *Mock) PullImage(image kubecontainer.ImageSpec, pullSecrets []v1.Secret, podSandboxConfig *runtimeapi.PodSandboxConfig) (string, error)

func (*Mock) RemoveImage 

func (r *Mock) RemoveImage(image kubecontainer.ImageSpec) error

func (*Mock) RunContainerInPod 

func (r *Mock) RunContainerInPod(container v1.Container, pod *v1.Pod, volumeMap map[string]volume.VolumePlugin) error

func (*Mock) Start 

func (r *Mock) Start() error

func (*Mock) Status 

func (r *Mock) Status() (*kubecontainer.RuntimeStatus, error)

func (*Mock) SupportsSingleFileMapping added in v1.17.0 

func (r *Mock) SupportsSingleFileMapping() bool

func (*Mock) SyncPod 

func (r *Mock) SyncPod(pod *v1.Pod, status *kubecontainer.PodStatus, secrets []v1.Secret, backOff *flowcontrol.Backoff) kubecontainer.PodSyncResult

func (*Mock) Type 

func (r *Mock) Type() string

func (*Mock) UpdatePodCIDR added in v1.5.0 

func (r *Mock) UpdatePodCIDR(c string) error

UpdatePodCIDR fulfills the cri interface.

func (*Mock) Version 

func (r *Mock) Version() (kubecontainer.Version, error)

type MockFileInfo added in v1.5.0 

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

Mock of FileInfo interface

func NewMockFileInfo added in v1.5.0 

func NewMockFileInfo(ctrl *gomock.Controller) *MockFileInfo

func (*MockFileInfo) EXPECT added in v1.5.0 

func (_m *MockFileInfo) EXPECT() *_MockFileInfoRecorder

func (*MockFileInfo) IsDir added in v1.5.0 

func (_m *MockFileInfo) IsDir() bool

func (*MockFileInfo) ModTime added in v1.5.0 

func (_m *MockFileInfo) ModTime() time.Time

func (*MockFileInfo) Mode added in v1.5.0 

func (_m *MockFileInfo) Mode() os.FileMode

func (*MockFileInfo) Name added in v1.5.0 

func (_m *MockFileInfo) Name() string

func (*MockFileInfo) Size added in v1.5.0 

func (_m *MockFileInfo) Size() int64

func (*MockFileInfo) Sys added in v1.5.0 

func (_m *MockFileInfo) Sys() interface{}

type MockRuntimeCache added in v1.8.0 

type MockRuntimeCache struct {
	mock.Mock
}

MockRuntimeCache is an autogenerated mock type for the RuntimeCache type

func (*MockRuntimeCache) ForceUpdateIfOlder added in v1.8.0 

func (_m *MockRuntimeCache) ForceUpdateIfOlder(_a0 time.Time) error

ForceUpdateIfOlder provides a mock function with given fields: _a0

func (*MockRuntimeCache) GetPods added in v1.8.0 

func (_m *MockRuntimeCache) GetPods() ([]*container.Pod, error)

GetPods provides a mock function with given fields:

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.