type TB … type FakePod … type FakeRuntime … const FakeHost … type FakeStreamingRuntime … var _ … var _ … type FakeVersion … func (fv *FakeVersion) String() string { … } func (fv *FakeVersion) Compare(other string) (int, error) { … } type podsGetter … type FakeRuntimeCache … func NewFakeRuntimeCache(getter podsGetter) kubecontainer.RuntimeCache { … } func (f *FakeRuntimeCache) GetPods(ctx context.Context) ([]*kubecontainer.Pod, error) { … } func (f *FakeRuntimeCache) ForceUpdateIfOlder(context.Context, time.Time) error { … } // UpdatePodCIDR fulfills the cri interface. func (f *FakeRuntime) UpdatePodCIDR(_ context.Context, c string) error { … } func (f *FakeRuntime) assertList(expect []string, test []string) bool { … } // AssertCalls test if the invoked functions are as expected. func (f *FakeRuntime) AssertCalls(calls []string) bool { … } // AssertCallCounts checks if a certain call is called for a certain of numbers func (f *FakeRuntime) AssertCallCounts(funcName string, expectedCount int) bool { … } func (f *FakeRuntime) AssertStartedPods(pods []string) bool { … } func (f *FakeRuntime) AssertKilledPods(pods []string) bool { … } func (f *FakeRuntime) AssertStartedContainers(containers []string) bool { … } func (f *FakeRuntime) AssertKilledContainers(containers []string) bool { … } func (f *FakeRuntime) Type() string { … } func (f *FakeRuntime) Version(_ context.Context) (kubecontainer.Version, error) { … } func (f *FakeRuntime) APIVersion() (kubecontainer.Version, error) { … } func (f *FakeRuntime) Status(_ context.Context) (*kubecontainer.RuntimeStatus, error) { … } func (f *FakeRuntime) GetPods(_ context.Context, all bool) ([]*kubecontainer.Pod, error) { … } func (f *FakeRuntime) SyncPod(_ context.Context, pod *v1.Pod, _ *kubecontainer.PodStatus, _ []v1.Secret, backOff *flowcontrol.Backoff) (result kubecontainer.PodSyncResult) { … } func (f *FakeRuntime) KillPod(_ context.Context, pod *v1.Pod, runningPod kubecontainer.Pod, gracePeriodOverride *int64) error { … } func (f *FakeRuntime) RunContainerInPod(container v1.Container, pod *v1.Pod, volumeMap map[string]volume.VolumePlugin) error { … } func (f *FakeRuntime) KillContainerInPod(container v1.Container, pod *v1.Pod) error { … } func (f *FakeRuntime) GeneratePodStatus(event *runtimeapi.ContainerEventResponse) (*kubecontainer.PodStatus, error) { … } func (f *FakeRuntime) GetPodStatus(_ context.Context, uid types.UID, name, namespace string) (*kubecontainer.PodStatus, error) { … } func (f *FakeRuntime) GetContainerLogs(_ context.Context, pod *v1.Pod, containerID kubecontainer.ContainerID, logOptions *v1.PodLogOptions, stdout, stderr io.Writer) (err error) { … } func (f *FakeRuntime) PullImage(ctx context.Context, image kubecontainer.ImageSpec, pullSecrets []v1.Secret, podSandboxConfig *runtimeapi.PodSandboxConfig) (string, error) { … } // UnblockImagePulls unblocks a certain number of image pulls, if BlockImagePulls is true. func (f *FakeRuntime) UnblockImagePulls(count int) { … } func (f *FakeRuntime) GetImageRef(_ context.Context, image kubecontainer.ImageSpec) (string, error) { … } func (f *FakeRuntime) GetImageSize(_ context.Context, image kubecontainer.ImageSpec) (uint64, error) { … } func (f *FakeRuntime) ListImages(_ context.Context) ([]kubecontainer.Image, error) { … } func snapshot(imageList []kubecontainer.Image) []kubecontainer.Image { … } func (f *FakeRuntime) RemoveImage(_ context.Context, image kubecontainer.ImageSpec) error { … } func (f *FakeRuntime) GarbageCollect(_ context.Context, gcPolicy kubecontainer.GCPolicy, ready bool, evictNonDeletedPods bool) error { … } func (f *FakeRuntime) DeleteContainer(_ context.Context, containerID kubecontainer.ContainerID) error { … } func (f *FakeRuntime) CheckpointContainer(_ context.Context, options *runtimeapi.CheckpointContainerRequest) error { … } func (f *FakeRuntime) ListMetricDescriptors(_ context.Context) ([]*runtimeapi.MetricDescriptor, error) { … } func (f *FakeRuntime) ListPodSandboxMetrics(_ context.Context) ([]*runtimeapi.PodSandboxMetrics, error) { … } // SetContainerFsStats sets the containerFsStats for dependency injection. func (f *FakeRuntime) SetContainerFsStats(val []*runtimeapi.FilesystemUsage) { … } // SetImageFsStats sets the ImageFsStats for dependency injection. func (f *FakeRuntime) SetImageFsStats(val []*runtimeapi.FilesystemUsage) { … } func (f *FakeRuntime) ImageStats(_ context.Context) (*kubecontainer.ImageStats, error) { … } // ImageFsInfo returns a ImageFsInfoResponse given the DI injected values of ImageFsStats // and ContainerFsStats. func (f *FakeRuntime) ImageFsInfo(_ context.Context) (*runtimeapi.ImageFsInfoResponse, error) { … } func (f *FakeStreamingRuntime) GetExec(_ context.Context, id kubecontainer.ContainerID, cmd []string, stdin, stdout, stderr, tty bool) (*url.URL, error) { … } func (f *FakeStreamingRuntime) GetAttach(_ context.Context, id kubecontainer.ContainerID, stdin, stdout, stderr, tty bool) (*url.URL, error) { … } func (f *FakeStreamingRuntime) GetPortForward(_ context.Context, podName, podNamespace string, podUID types.UID, ports []int32) (*url.URL, error) { … } type FakeContainerCommandRunner … var _ … func (f *FakeContainerCommandRunner) RunInContainer(_ context.Context, containerID kubecontainer.ContainerID, cmd []string, timeout time.Duration) ([]byte, error) { … } func (f *FakeRuntime) GetContainerStatus(_ context.Context, _ kubecontainer.ContainerID) (status *kubecontainer.Status, err error) { … }
Codebase Browser
kubernetes