kubernetes – k8s.io/kubernetes/pkg/kubelet/container/testing Index | Files

package testing

import "k8s.io/kubernetes/pkg/kubelet/container/testing"

Index

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

fake_cache.go fake_runtime.go os.go runtime_mock.go

Version
v1.4.1-beta.0
Published
Sep 26, 2016
Platform
js/wasm
Imports
14 packages
Last checked
2 minutes ago –

Tools for package owners.