const Version … const RunPodSandbox … const StopPodSandbox … const RemovePodSandbox … const PodSandboxStatus … const ListPodSandbox … const CreateContainer … const StartContainer … const StopContainer … const RemoveContainer … const ListContainers … const ContainerStatus … const UpdateContainerResources … const ReopenContainerLog … const ExecSync … const Exec … const Attach … const PortForward … const ContainerStats … const ListContainerStats … const PodSandboxStats … const ListPodSandboxStats … const UpdateRuntimeConfig … const Status … const CheckpointContainer … const GetContainerEvents … const ListMetricDescriptors … const ListPodSandboxMetrics … const RuntimeConfig … // AddInjector inject the error or delay to the next call to the RuntimeService. func (p *RemoteRuntime) AddInjector(injector func(string) error) { … } // ResetInjectors resets all registered injectors. func (p *RemoteRuntime) ResetInjectors() { … } func (p *RemoteRuntime) runInjectors(apiName string) error { … } type RemoteRuntime … // NewRemoteRuntimeProxy creates a new RemoteRuntime. func NewRemoteRuntimeProxy(runtimeService internalapi.RuntimeService, imageService internalapi.ImageManagerService) *RemoteRuntime { … } // Start starts the remote runtime proxy. func (p *RemoteRuntime) Start(endpoint string) error { … } // Stop stops the fake remote runtime proxy. func (p *RemoteRuntime) Stop() { … } // Version returns the runtime name, runtime version, and runtime API version. func (p *RemoteRuntime) Version(ctx context.Context, req *runtimeapi.VersionRequest) (*runtimeapi.VersionResponse, error) { … } // RunPodSandbox creates and starts a pod-level sandbox. Runtimes must ensure // the sandbox is in the ready state on success. func (p *RemoteRuntime) RunPodSandbox(ctx context.Context, req *runtimeapi.RunPodSandboxRequest) (*runtimeapi.RunPodSandboxResponse, error) { … } // StopPodSandbox stops any running process that is part of the sandbox and // reclaims network resources (e.g., IP addresses) allocated to the sandbox. // If there are any running containers in the sandbox, they must be forcibly // terminated. func (p *RemoteRuntime) StopPodSandbox(ctx context.Context, req *runtimeapi.StopPodSandboxRequest) (*runtimeapi.StopPodSandboxResponse, error) { … } // RemovePodSandbox removes the sandbox. If there are any running containers // in the sandbox, they must be forcibly terminated and removed. // This call is idempotent, and must not return an error if the sandbox has // already been removed. func (p *RemoteRuntime) RemovePodSandbox(ctx context.Context, req *runtimeapi.RemovePodSandboxRequest) (*runtimeapi.RemovePodSandboxResponse, error) { … } // PodSandboxStatus returns the status of the PodSandbox. If the PodSandbox is not // present, returns an error. func (p *RemoteRuntime) PodSandboxStatus(ctx context.Context, req *runtimeapi.PodSandboxStatusRequest) (*runtimeapi.PodSandboxStatusResponse, error) { … } // ListPodSandbox returns a list of PodSandboxes. func (p *RemoteRuntime) ListPodSandbox(ctx context.Context, req *runtimeapi.ListPodSandboxRequest) (*runtimeapi.ListPodSandboxResponse, error) { … } // CreateContainer creates a new container in specified PodSandbox func (p *RemoteRuntime) CreateContainer(ctx context.Context, req *runtimeapi.CreateContainerRequest) (*runtimeapi.CreateContainerResponse, error) { … } // StartContainer starts the container. func (p *RemoteRuntime) StartContainer(ctx context.Context, req *runtimeapi.StartContainerRequest) (*runtimeapi.StartContainerResponse, error) { … } // StopContainer stops a running container with a grace period (i.e., timeout). // This call is idempotent, and must not return an error if the container has // already been stopped. func (p *RemoteRuntime) StopContainer(ctx context.Context, req *runtimeapi.StopContainerRequest) (*runtimeapi.StopContainerResponse, error) { … } // RemoveContainer removes the container. If the container is running, the // container must be forcibly removed. // This call is idempotent, and must not return an error if the container has // already been removed. func (p *RemoteRuntime) RemoveContainer(ctx context.Context, req *runtimeapi.RemoveContainerRequest) (*runtimeapi.RemoveContainerResponse, error) { … } // ListContainers lists all containers by filters. func (p *RemoteRuntime) ListContainers(ctx context.Context, req *runtimeapi.ListContainersRequest) (*runtimeapi.ListContainersResponse, error) { … } // ContainerStatus returns status of the container. If the container is not // present, returns an error. func (p *RemoteRuntime) ContainerStatus(ctx context.Context, req *runtimeapi.ContainerStatusRequest) (*runtimeapi.ContainerStatusResponse, error) { … } // ExecSync runs a command in a container synchronously. func (p *RemoteRuntime) ExecSync(ctx context.Context, req *runtimeapi.ExecSyncRequest) (*runtimeapi.ExecSyncResponse, error) { … } // Exec prepares a streaming endpoint to execute a command in the container. func (p *RemoteRuntime) Exec(ctx context.Context, req *runtimeapi.ExecRequest) (*runtimeapi.ExecResponse, error) { … } // Attach prepares a streaming endpoint to attach to a running container. func (p *RemoteRuntime) Attach(ctx context.Context, req *runtimeapi.AttachRequest) (*runtimeapi.AttachResponse, error) { … } // PortForward prepares a streaming endpoint to forward ports from a PodSandbox. func (p *RemoteRuntime) PortForward(ctx context.Context, req *runtimeapi.PortForwardRequest) (*runtimeapi.PortForwardResponse, error) { … } // ContainerStats returns stats of the container. If the container does not // exist, the call returns an error. func (p *RemoteRuntime) ContainerStats(ctx context.Context, req *runtimeapi.ContainerStatsRequest) (*runtimeapi.ContainerStatsResponse, error) { … } // ListContainerStats returns stats of all running containers. func (p *RemoteRuntime) ListContainerStats(ctx context.Context, req *runtimeapi.ListContainerStatsRequest) (*runtimeapi.ListContainerStatsResponse, error) { … } // PodSandboxStats returns stats of the pod. If the pod does not // exist, the call returns an error. func (p *RemoteRuntime) PodSandboxStats(ctx context.Context, req *runtimeapi.PodSandboxStatsRequest) (*runtimeapi.PodSandboxStatsResponse, error) { … } // ListPodSandboxStats returns stats of all running pods. func (p *RemoteRuntime) ListPodSandboxStats(ctx context.Context, req *runtimeapi.ListPodSandboxStatsRequest) (*runtimeapi.ListPodSandboxStatsResponse, error) { … } // UpdateRuntimeConfig updates the runtime configuration based on the given request. func (p *RemoteRuntime) UpdateRuntimeConfig(ctx context.Context, req *runtimeapi.UpdateRuntimeConfigRequest) (*runtimeapi.UpdateRuntimeConfigResponse, error) { … } // Status returns the status of the runtime. func (p *RemoteRuntime) Status(ctx context.Context, req *runtimeapi.StatusRequest) (*runtimeapi.StatusResponse, error) { … } // UpdateContainerResources updates ContainerConfig of the container. func (p *RemoteRuntime) UpdateContainerResources(ctx context.Context, req *runtimeapi.UpdateContainerResourcesRequest) (*runtimeapi.UpdateContainerResourcesResponse, error) { … } // ReopenContainerLog reopens the container log file. func (p *RemoteRuntime) ReopenContainerLog(ctx context.Context, req *runtimeapi.ReopenContainerLogRequest) (*runtimeapi.ReopenContainerLogResponse, error) { … } // CheckpointContainer checkpoints the given container. func (p *RemoteRuntime) CheckpointContainer(ctx context.Context, req *runtimeapi.CheckpointContainerRequest) (*runtimeapi.CheckpointContainerResponse, error) { … } func (p *RemoteRuntime) GetContainerEvents(req *runtimeapi.GetEventsRequest, ces runtimeapi.RuntimeService_GetContainerEventsServer) error { … } // ListMetricDescriptors gets the descriptors for the metrics that will be returned in ListPodSandboxMetrics. func (p *RemoteRuntime) ListMetricDescriptors(ctx context.Context, req *runtimeapi.ListMetricDescriptorsRequest) (*runtimeapi.ListMetricDescriptorsResponse, error) { … } // ListPodSandboxMetrics retrieves the metrics for all pod sandboxes. func (p *RemoteRuntime) ListPodSandboxMetrics(ctx context.Context, req *runtimeapi.ListPodSandboxMetricsRequest) (*runtimeapi.ListPodSandboxMetricsResponse, error) { … } // RuntimeConfig returns the configuration information of the runtime. func (p *RemoteRuntime) RuntimeConfig(ctx context.Context, req *runtimeapi.RuntimeConfigRequest) (*runtimeapi.RuntimeConfigResponse, error) { … }
Codebase Browser
kubernetes