testing

package
v1.3.0-alpha.0 Latest Latest
Warning

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

Go to latest
Published: Mar 4, 2016 License: Apache-2.0 Imports: 12 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{}

FakeOS mocks out certain OS calls to avoid perturbing the filesystem on the test machine.

func (FakeOS) Mkdir

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

Mkdir is a fake call that just returns nil.

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

Symlink is a fake call that just returns nil.

type FakeRuntime

type FakeRuntime struct {
	sync.Mutex
	CalledFunctions   []string
	PodList           []*Pod
	AllPodList        []*Pod
	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
}

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

func (*FakeRuntime) ClearCalls

func (f *FakeRuntime) ClearCalls()

ClearCalls resets the FakeRuntime to the initial state.

func (*FakeRuntime) ExecInContainer

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

func (*FakeRuntime) GarbageCollect

func (f *FakeRuntime) GarbageCollect(gcPolicy ContainerGCPolicy) error

func (*FakeRuntime) GetContainerLogs

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

func (f *FakeRuntime) RunInContainer(containerID ContainerID, cmd []string) ([]byte, error)

func (*FakeRuntime) SyncPod

func (f *FakeRuntime) SyncPod(pod *api.Pod, _ api.PodStatus, _ *PodStatus, _ []api.Secret, backOff *util.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) error

func (*Mock) ExecInContainer

func (r *Mock) ExecInContainer(containerID ContainerID, cmd []string, stdin io.Reader, stdout, stderr io.WriteCloser, tty bool) error

func (*Mock) GarbageCollect

func (r *Mock) GarbageCollect(gcPolicy ContainerGCPolicy) error

func (*Mock) GetContainerLogs

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

func (r *Mock) RunInContainer(containerID ContainerID, cmd []string) ([]byte, error)

func (*Mock) Start

func (r *Mock) Start() error

func (*Mock) SyncPod

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

func (*Mock) Type

func (r *Mock) Type() string

func (*Mock) Version

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

Jump to

Keyboard shortcuts

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