testing

package
v0.0.0-...-112d741 Latest Latest
Warning

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

 Go to latest Published: Jul 11, 2017 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

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) RuntimeCache

Types

type FakeContainerCommandRunner 

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

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

func (*FakeContainerCommandRunner) RunInContainer 

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

type FakeDirectStreamingRuntime 

type FakeDirectStreamingRuntime struct {
	*FakeRuntime

	// Arguments to streaming method calls.
	Args struct {
		// Attach / Exec args
		ContainerID ContainerID
		Cmd         []string
		Stdin       io.Reader
		Stdout      io.WriteCloser
		Stderr      io.WriteCloser
		TTY         bool
		// Port-forward args
		Pod    *Pod
		Port   int32
		Stream io.ReadWriteCloser
	}
}

func (*FakeDirectStreamingRuntime) AttachContainer 

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

func (*FakeDirectStreamingRuntime) ExecInContainer 

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

func (*FakeDirectStreamingRuntime) PortForward 

func (f *FakeDirectStreamingRuntime) PortForward(pod *Pod, port int32, stream io.ReadWriteCloser) error

type FakeIndirectStreamingRuntime 

type FakeIndirectStreamingRuntime struct {
	*FakeRuntime
}

func (*FakeIndirectStreamingRuntime) GetAttach 

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

func (*FakeIndirectStreamingRuntime) GetExec 

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

func (*FakeIndirectStreamingRuntime) GetPortForward 

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

func NewFakeOS() *FakeOS

func (FakeOS) Chmod 

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

Chmod is a fake call that returns nil.

func (FakeOS) Chtimes 

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

Chtimes is a fake call that returns nil.

func (FakeOS) Create 

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

Create is a fake call that returns nil.

func (*FakeOS) Glob 

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

Glob is a fake call that returns nil.

func (*FakeOS) Hostname 

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

Hostname is a fake call that returns nil.

func (*FakeOS) MkdirAll 

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

Mkdir is a fake call that just returns nil.

func (FakeOS) Pipe 

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

Pipe is a fake call that returns nil.

func (*FakeOS) ReadDir 

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

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

func (*FakeOS) Remove 

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

Remove is a fake call that returns nil.

func (*FakeOS) RemoveAll 

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

RemoveAll is a fake call that just returns nil.

func (FakeOS) Stat 

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 

type FakePod struct {
	Pod       *Pod
	NetnsPath string
}

type FakeRuntime 

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

FakeRuntime is a fake container runtime for testing.

func (*FakeRuntime) APIVersion 

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

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) ClearCalls 

func (f *FakeRuntime) ClearCalls()

ClearCalls resets the FakeRuntime to the initial state.

func (*FakeRuntime) DeleteContainer 

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

func (*FakeRuntime) GarbageCollect 

func (f *FakeRuntime) GarbageCollect(gcPolicy ContainerGCPolicy, ready bool, evictNonDeletedPods bool) error

func (*FakeRuntime) GetContainerLogs 

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

func (*FakeRuntime) GetImageRef 

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

func (*FakeRuntime) GetNetNS 

func (f *FakeRuntime) GetNetNS(containerID ContainerID) (string, error)

func (*FakeRuntime) GetPodContainerID 

func (f *FakeRuntime) GetPodContainerID(pod *Pod) (ContainerID, error)

func (*FakeRuntime) GetPodStatus 

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

func (*FakeRuntime) GetPods 

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

func (*FakeRuntime) ImageStats 

func (f *FakeRuntime) ImageStats() (*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 Pod, gracePeriodOverride *int64) error

func (*FakeRuntime) ListImages 

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

func (*FakeRuntime) PullImage 

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

func (*FakeRuntime) RemoveImage 

func (f *FakeRuntime) RemoveImage(image 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() (*RuntimeStatus, error)

func (*FakeRuntime) SyncPod 

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

func (*FakeRuntime) Type 

func (f *FakeRuntime) Type() string

func (*FakeRuntime) UpdatePodCIDR 

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

UpdatePodCIDR fulfills the cri interface.

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 FakeRuntimeHelper 

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

FakeRuntimeHelper implements RuntimeHelper interfaces for testing purposes.

func (*FakeRuntimeHelper) GeneratePodHostNameAndDomain 

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

This is not used by docker runtime.

func (*FakeRuntimeHelper) GenerateRunContainerOptions 

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

func (*FakeRuntimeHelper) GetClusterDNS 

func (f *FakeRuntimeHelper) GetClusterDNS(pod *v1.Pod) ([]string, []string, bool, error)

func (*FakeRuntimeHelper) GetExtraSupplementalGroupsForPod 

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

func (*FakeRuntimeHelper) GetPodCgroupParent 

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

func (*FakeRuntimeHelper) GetPodDir 

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

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() (Version, error)

func (*Mock) AttachContainer 

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

func (*Mock) DeleteContainer 

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

func (*Mock) ExecInContainer 

func (r *Mock) ExecInContainer(containerID 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 ContainerGCPolicy, ready bool, evictNonDeletedPods bool) error

func (*Mock) GetContainerLogs 

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

func (*Mock) GetImageRef 

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

func (*Mock) GetNetNS 

func (r *Mock) GetNetNS(containerID ContainerID) (string, error)

func (*Mock) GetPodContainerID 

func (r *Mock) GetPodContainerID(pod *Pod) (ContainerID, error)

func (*Mock) GetPodStatus 

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

func (*Mock) GetPods 

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

func (*Mock) ImageStats 

func (r *Mock) ImageStats() (*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 Pod, gracePeriodOverride *int64) error

func (*Mock) ListImages 

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

func (*Mock) PortForward 

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

func (*Mock) PullImage 

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

func (*Mock) RemoveImage 

func (r *Mock) RemoveImage(image 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() (*RuntimeStatus, error)

func (*Mock) SyncPod 

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

func (*Mock) Type 

func (r *Mock) Type() string

func (*Mock) UpdatePodCIDR 

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

UpdatePodCIDR fulfills the cri interface.

func (*Mock) Version 

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

type MockFileInfo 

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

Mock of FileInfo interface

func NewMockFileInfo 

func NewMockFileInfo(ctrl *gomock.Controller) *MockFileInfo

func (*MockFileInfo) EXPECT 

func (_m *MockFileInfo) EXPECT() *_MockFileInfoRecorder

func (*MockFileInfo) IsDir 

func (_m *MockFileInfo) IsDir() bool

func (*MockFileInfo) ModTime 

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

func (*MockFileInfo) Mode 

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

func (*MockFileInfo) Name 

func (_m *MockFileInfo) Name() string

func (*MockFileInfo) Size 

func (_m *MockFileInfo) Size() int64

func (*MockFileInfo) Sys 

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

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.