var FakeVersion … var FakeRuntimeName … var FakePodSandboxIPs … type FakePodSandbox … type FakeContainer … type FakeRuntimeService … // GetContainerID returns the unique container ID from the FakeRuntimeService. func (r *FakeRuntimeService) GetContainerID(sandboxID, name string, attempt uint32) (string, error) { … } // SetFakeSandboxes sets the fake sandboxes for the FakeRuntimeService. func (r *FakeRuntimeService) SetFakeSandboxes(sandboxes []*FakePodSandbox) { … } // SetFakeContainers sets fake containers for the FakeRuntimeService. func (r *FakeRuntimeService) SetFakeContainers(containers []*FakeContainer) { … } // AssertCalls validates whether specified calls were made to the FakeRuntimeService. func (r *FakeRuntimeService) AssertCalls(calls []string) error { … } // GetCalls returns the list of calls made to the FakeRuntimeService. func (r *FakeRuntimeService) GetCalls() []string { … } // InjectError inject the error to the next call to the FakeRuntimeService. func (r *FakeRuntimeService) InjectError(f string, err error) { … } // caller of popError must grab a lock. func (r *FakeRuntimeService) popError(f string) error { … } // NewFakeRuntimeService creates a new FakeRuntimeService. func NewFakeRuntimeService() *FakeRuntimeService { … } // Version returns version information from the FakeRuntimeService. func (r *FakeRuntimeService) Version(_ context.Context, apiVersion string) (*runtimeapi.VersionResponse, error) { … } // Status returns runtime status of the FakeRuntimeService. func (r *FakeRuntimeService) Status(_ context.Context, verbose bool) (*runtimeapi.StatusResponse, error) { … } // RunPodSandbox emulates the run of the pod sandbox in the FakeRuntimeService. func (r *FakeRuntimeService) RunPodSandbox(_ context.Context, config *runtimeapi.PodSandboxConfig, runtimeHandler string) (string, error) { … } // StopPodSandbox emulates the stop of pod sandbox in the FakeRuntimeService. func (r *FakeRuntimeService) StopPodSandbox(_ context.Context, podSandboxID string) error { … } // RemovePodSandbox emulates removal of the pod sadbox in the FakeRuntimeService. func (r *FakeRuntimeService) RemovePodSandbox(_ context.Context, podSandboxID string) error { … } // PodSandboxStatus returns pod sandbox status from the FakeRuntimeService. func (r *FakeRuntimeService) PodSandboxStatus(_ context.Context, podSandboxID string, verbose bool) (*runtimeapi.PodSandboxStatusResponse, error) { … } // ListPodSandbox returns the list of pod sandboxes in the FakeRuntimeService. func (r *FakeRuntimeService) ListPodSandbox(_ context.Context, filter *runtimeapi.PodSandboxFilter) ([]*runtimeapi.PodSandbox, error) { … } // PortForward emulates the set up of port forward in the FakeRuntimeService. func (r *FakeRuntimeService) PortForward(context.Context, *runtimeapi.PortForwardRequest) (*runtimeapi.PortForwardResponse, error) { … } // CreateContainer emulates container creation in the FakeRuntimeService. func (r *FakeRuntimeService) CreateContainer(_ context.Context, podSandboxID string, config *runtimeapi.ContainerConfig, sandboxConfig *runtimeapi.PodSandboxConfig) (string, error) { … } // StartContainer emulates start of a container in the FakeRuntimeService. func (r *FakeRuntimeService) StartContainer(_ context.Context, containerID string) error { … } // StopContainer emulates stop of a container in the FakeRuntimeService. func (r *FakeRuntimeService) StopContainer(_ context.Context, containerID string, timeout int64) error { … } // RemoveContainer emulates remove of a container in the FakeRuntimeService. func (r *FakeRuntimeService) RemoveContainer(_ context.Context, containerID string) error { … } // ListContainers returns the list of containers in the FakeRuntimeService. func (r *FakeRuntimeService) ListContainers(_ context.Context, filter *runtimeapi.ContainerFilter) ([]*runtimeapi.Container, error) { … } // ContainerStatus returns the container status given the container ID in FakeRuntimeService. func (r *FakeRuntimeService) ContainerStatus(_ context.Context, containerID string, verbose bool) (*runtimeapi.ContainerStatusResponse, error) { … } // UpdateContainerResources returns the container resource in the FakeRuntimeService. func (r *FakeRuntimeService) UpdateContainerResources(context.Context, string, *runtimeapi.ContainerResources) error { … } // ExecSync emulates the sync execution of a command in a container in the FakeRuntimeService. func (r *FakeRuntimeService) ExecSync(_ context.Context, containerID string, cmd []string, timeout time.Duration) (stdout []byte, stderr []byte, err error) { … } // Exec emulates the execution of a command in a container in the FakeRuntimeService. func (r *FakeRuntimeService) Exec(context.Context, *runtimeapi.ExecRequest) (*runtimeapi.ExecResponse, error) { … } // Attach emulates the attach request in the FakeRuntimeService. func (r *FakeRuntimeService) Attach(_ context.Context, req *runtimeapi.AttachRequest) (*runtimeapi.AttachResponse, error) { … } // UpdateRuntimeConfig emulates the update of a runtime config for the FakeRuntimeService. func (r *FakeRuntimeService) UpdateRuntimeConfig(_ context.Context, runtimeCOnfig *runtimeapi.RuntimeConfig) error { … } // SetFakeContainerStats sets the fake container stats in the FakeRuntimeService. func (r *FakeRuntimeService) SetFakeContainerStats(containerStats []*runtimeapi.ContainerStats) { … } // ContainerStats returns the container stats in the FakeRuntimeService. func (r *FakeRuntimeService) ContainerStats(_ context.Context, containerID string) (*runtimeapi.ContainerStats, error) { … } // ListContainerStats returns the list of all container stats given the filter in the FakeRuntimeService. func (r *FakeRuntimeService) ListContainerStats(_ context.Context, filter *runtimeapi.ContainerStatsFilter) ([]*runtimeapi.ContainerStats, error) { … } // SetFakePodSandboxStats sets the fake pod sandbox stats in the FakeRuntimeService. func (r *FakeRuntimeService) SetFakePodSandboxStats(podStats []*runtimeapi.PodSandboxStats) { … } // PodSandboxStats returns the sandbox stats in the FakeRuntimeService. func (r *FakeRuntimeService) PodSandboxStats(_ context.Context, podSandboxID string) (*runtimeapi.PodSandboxStats, error) { … } // ListPodSandboxStats returns the list of all pod sandbox stats given the filter in the FakeRuntimeService. func (r *FakeRuntimeService) ListPodSandboxStats(_ context.Context, filter *runtimeapi.PodSandboxStatsFilter) ([]*runtimeapi.PodSandboxStats, error) { … } // ReopenContainerLog emulates call to the reopen container log in the FakeRuntimeService. func (r *FakeRuntimeService) ReopenContainerLog(_ context.Context, containerID string) error { … } // CheckpointContainer emulates call to checkpoint a container in the FakeRuntimeService. func (r *FakeRuntimeService) CheckpointContainer(_ context.Context, options *runtimeapi.CheckpointContainerRequest) error { … } func (f *FakeRuntimeService) GetContainerEvents(ctx context.Context, containerEventsCh chan *runtimeapi.ContainerEventResponse, connectionEstablishedCallback func(runtimeapi.RuntimeService_GetContainerEventsClient)) error { … } // SetFakeMetricDescriptors sets the fake metrics descriptors in the FakeRuntimeService. func (r *FakeRuntimeService) SetFakeMetricDescriptors(descs []*runtimeapi.MetricDescriptor) { … } // ListMetricDescriptors gets the descriptors for the metrics that will be returned in ListPodSandboxMetrics. func (r *FakeRuntimeService) ListMetricDescriptors(_ context.Context) ([]*runtimeapi.MetricDescriptor, error) { … } // SetFakePodSandboxMetrics sets the fake pod sandbox metrics in the FakeRuntimeService. func (r *FakeRuntimeService) SetFakePodSandboxMetrics(podStats []*runtimeapi.PodSandboxMetrics) { … } // ListPodSandboxMetrics returns the list of all pod sandbox metrics in the FakeRuntimeService. func (r *FakeRuntimeService) ListPodSandboxMetrics(_ context.Context) ([]*runtimeapi.PodSandboxMetrics, error) { … } // RuntimeConfig returns runtime configuration of the FakeRuntimeService. func (r *FakeRuntimeService) RuntimeConfig(_ context.Context) (*runtimeapi.RuntimeConfigResponse, error) { … }
Codebase Browser
kubernetes