Documentation ¶
Index ¶
- func NewFakeCache(runtime container.Runtime) container.Cache
- func NewFakeRuntimeCache(getter podsGetter) RuntimeCache
- type FakeOS
- type FakeRuntime
- func (f *FakeRuntime) APIVersion() (Version, error)
- func (f *FakeRuntime) AssertCalls(calls []string) error
- func (f *FakeRuntime) AssertKilledContainers(containers []string) error
- func (f *FakeRuntime) AssertKilledPods(pods []string) error
- func (f *FakeRuntime) AssertStartedContainers(containers []string) error
- func (f *FakeRuntime) AssertStartedPods(pods []string) error
- func (f *FakeRuntime) AttachContainer(containerID ContainerID, stdin io.Reader, stdout, stderr io.WriteCloser, ...) error
- func (f *FakeRuntime) ClearCalls()
- func (f *FakeRuntime) ExecInContainer(containerID ContainerID, cmd []string, stdin io.Reader, ...) error
- func (f *FakeRuntime) GarbageCollect(gcPolicy ContainerGCPolicy) error
- func (f *FakeRuntime) GetContainerLogs(pod *api.Pod, containerID ContainerID, logOptions *api.PodLogOptions, ...) (err error)
- func (f *FakeRuntime) GetPodStatus(uid types.UID, name, namespace string) (*PodStatus, error)
- func (f *FakeRuntime) GetPods(all bool) ([]*Pod, error)
- func (f *FakeRuntime) IsImagePresent(image ImageSpec) (bool, error)
- func (f *FakeRuntime) KillContainerInPod(container api.Container, pod *api.Pod) error
- func (f *FakeRuntime) KillPod(pod *api.Pod, runningPod Pod) error
- func (f *FakeRuntime) ListImages() ([]Image, error)
- func (f *FakeRuntime) PortForward(pod *Pod, port uint16, stream io.ReadWriteCloser) error
- func (f *FakeRuntime) PullImage(image ImageSpec, pullSecrets []api.Secret) error
- func (f *FakeRuntime) RemoveImage(image ImageSpec) error
- func (f *FakeRuntime) RunContainerInPod(container api.Container, pod *api.Pod, ...) error
- func (f *FakeRuntime) RunInContainer(containerID ContainerID, cmd []string) ([]byte, error)
- func (f *FakeRuntime) SyncPod(pod *api.Pod, _ api.PodStatus, _ *PodStatus, _ []api.Secret, ...) (result PodSyncResult)
- func (f *FakeRuntime) Type() string
- func (f *FakeRuntime) Version() (Version, error)
- type FakeRuntimeCache
- type FakeVersion
- type Mock
- func (r *Mock) APIVersion() (Version, error)
- func (r *Mock) AttachContainer(containerID ContainerID, stdin io.Reader, stdout, stderr io.WriteCloser, ...) error
- func (r *Mock) ExecInContainer(containerID ContainerID, cmd []string, stdin io.Reader, ...) error
- func (r *Mock) GarbageCollect(gcPolicy ContainerGCPolicy) error
- func (r *Mock) GetContainerLogs(pod *api.Pod, containerID ContainerID, logOptions *api.PodLogOptions, ...) (err error)
- func (r *Mock) GetPodStatus(uid types.UID, name, namespace string) (*PodStatus, error)
- func (r *Mock) GetPods(all bool) ([]*Pod, error)
- func (r *Mock) IsImagePresent(image ImageSpec) (bool, error)
- func (r *Mock) KillContainerInPod(container api.Container, pod *api.Pod) error
- func (r *Mock) KillPod(pod *api.Pod, runningPod Pod) error
- func (r *Mock) ListImages() ([]Image, error)
- func (r *Mock) PortForward(pod *Pod, port uint16, stream io.ReadWriteCloser) error
- func (r *Mock) PullImage(image ImageSpec, pullSecrets []api.Secret) error
- func (r *Mock) RemoveImage(image ImageSpec) error
- func (r *Mock) RunContainerInPod(container api.Container, pod *api.Pod, ...) error
- func (r *Mock) RunInContainer(containerID ContainerID, cmd []string) ([]byte, error)
- func (r *Mock) Start() error
- func (r *Mock) SyncPod(pod *api.Pod, apiStatus api.PodStatus, status *PodStatus, secrets []api.Secret, ...) PodSyncResult
- func (r *Mock) Type() string
- func (r *Mock) Version() (Version, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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.
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 (*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) 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) String ¶
func (fv *FakeVersion) String() string
type Mock ¶
func (*Mock) APIVersion ¶
func (*Mock) AttachContainer ¶
func (*Mock) ExecInContainer ¶
func (*Mock) GarbageCollect ¶
func (*Mock) GetContainerLogs ¶
func (*Mock) GetPodStatus ¶
func (*Mock) IsImagePresent ¶
func (*Mock) KillContainerInPod ¶
func (*Mock) ListImages ¶
func (*Mock) PortForward ¶
func (r *Mock) PortForward(pod *Pod, port uint16, stream io.ReadWriteCloser) error
func (*Mock) RemoveImage ¶
func (*Mock) RunContainerInPod ¶
func (*Mock) RunInContainer ¶
Click to show internal directories.
Click to hide internal directories.