testing

package
v1.4.2-beta.0 Latest Latest
Warning

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

 Go to latest Published: Oct 10, 2016 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewFakeCache 

func NewFakeCache(runtime container.Runtime) container.Cache

func NewFakeRuntimeCache 

func NewFakeRuntimeCache(getter podsGetter) RuntimeCache

Types

type FakeOS 

type FakeOS struct {
	StatFn    func(string) (os.FileInfo, error)
	ReadDirFn func(string) ([]os.FileInfo, 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) 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) Hostname 

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

Hostname is a fake call that returns nil.

func (FakeOS) MkdirAll 

func (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) Stat 

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

Stat is a fake that returns an error 

func (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      api.PodStatus
	PodStatus         PodStatus
	StartedPods       []string
	KilledPods        []string
	StartedContainers []string
	KilledContainers  []string
	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) AttachContainer 

func (f *FakeRuntime) AttachContainer(containerID ContainerID, stdin io.Reader, stdout, stderr io.WriteCloser, tty bool, resize <-chan term.Size) 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) ExecInContainer 

func (f *FakeRuntime) ExecInContainer(containerID ContainerID, cmd []string, stdin io.Reader, stdout, stderr io.WriteCloser, tty bool, resize <-chan term.Size) error

func (*FakeRuntime) GarbageCollect 

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

func (*FakeRuntime) GetContainerLogs 

func (f *FakeRuntime) GetContainerLogs(pod *api.Pod, containerID ContainerID, logOptions *api.PodLogOptions, stdout, stderr io.Writer) (err 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) IsImagePresent 

func (f *FakeRuntime) IsImagePresent(image ImageSpec) (bool, error)

func (*FakeRuntime) KillContainerInPod 

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

func (*FakeRuntime) KillPod 

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

func (*FakeRuntime) ListImages 

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

func (*FakeRuntime) PortForward 

func (f *FakeRuntime) PortForward(pod *Pod, port uint16, stream io.ReadWriteCloser) error

func (*FakeRuntime) PullImage 

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

func (*FakeRuntime) RemoveImage 

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

func (*FakeRuntime) RunContainerInPod 

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

func (*FakeRuntime) Status 

func (f *FakeRuntime) Status() error

func (*FakeRuntime) SyncPod 

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

func (*FakeRuntime) Type 

func (f *FakeRuntime) Type() string

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

func (*Mock) GarbageCollect 

func (r *Mock) GarbageCollect(gcPolicy ContainerGCPolicy, ready bool) error

func (*Mock) GetContainerLogs 

func (r *Mock) GetContainerLogs(pod *api.Pod, containerID ContainerID, logOptions *api.PodLogOptions, stdout, stderr io.Writer) (err 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) IsImagePresent 

func (r *Mock) IsImagePresent(image ImageSpec) (bool, error)

func (*Mock) KillContainerInPod 

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

func (*Mock) KillPod 

func (r *Mock) KillPod(pod *api.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 []api.Secret) error

func (*Mock) RemoveImage 

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

func (*Mock) RunContainerInPod 

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

func (*Mock) Start 

func (r *Mock) Start() error

func (*Mock) Status 

func (r *Mock) Status() error

func (*Mock) SyncPod 

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

func (*Mock) Type 

func (r *Mock) Type() string

func (*Mock) Version 

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

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.