testing

package
v0.15.1-0...-d7b79a7 Latest Latest
Warning

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

Go to latest
Published: Mar 16, 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 term.Size) error

func (*FakeDirectStreamingRuntime) ExecInContainer

func (f *FakeDirectStreamingRuntime) ExecInContainer(containerID ContainerID, cmd []string, stdin io.Reader, stdout, stderr io.WriteCloser, tty bool, resize <-chan term.Size, 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) 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 term.Size) 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 term.Size, timeout time.Duration) error

func (*Mock) GarbageCollect

func (r *Mock) GarbageCollect(gcPolicy ContainerGCPolicy, ready 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{}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL