Documentation ¶
Index ¶
- type ContivshimManager
- func (s *ContivshimManager) Attach(ctx context.Context, req *kubeapi.AttachRequest) (*kubeapi.AttachResponse, error)
- func (s *ContivshimManager) ContainerStats(ctx context.Context, req *kubeapi.ContainerStatsRequest) (*kubeapi.ContainerStatsResponse, error)
- func (s *ContivshimManager) ContainerStatus(ctx context.Context, req *kubeapi.ContainerStatusRequest) (*kubeapi.ContainerStatusResponse, error)
- func (s *ContivshimManager) CreateContainer(ctx context.Context, req *kubeapi.CreateContainerRequest) (*kubeapi.CreateContainerResponse, error)
- func (s *ContivshimManager) Exec(ctx context.Context, req *kubeapi.ExecRequest) (*kubeapi.ExecResponse, error)
- func (s *ContivshimManager) ExecSync(ctx context.Context, req *kubeapi.ExecSyncRequest) (*kubeapi.ExecSyncResponse, error)
- func (s *ContivshimManager) ImageFsInfo(ctx context.Context, req *kubeapi.ImageFsInfoRequest) (*kubeapi.ImageFsInfoResponse, error)
- func (s *ContivshimManager) ImageStatus(ctx context.Context, req *kubeapi.ImageStatusRequest) (*kubeapi.ImageStatusResponse, error)
- func (s *ContivshimManager) ListContainerStats(ctx context.Context, req *kubeapi.ListContainerStatsRequest) (*kubeapi.ListContainerStatsResponse, error)
- func (s *ContivshimManager) ListContainers(ctx context.Context, req *kubeapi.ListContainersRequest) (*kubeapi.ListContainersResponse, error)
- func (s *ContivshimManager) ListImages(ctx context.Context, req *kubeapi.ListImagesRequest) (*kubeapi.ListImagesResponse, error)
- func (s *ContivshimManager) ListPodSandbox(ctx context.Context, req *kubeapi.ListPodSandboxRequest) (*kubeapi.ListPodSandboxResponse, error)
- func (s *ContivshimManager) PodSandboxStatus(ctx context.Context, req *kubeapi.PodSandboxStatusRequest) (*kubeapi.PodSandboxStatusResponse, error)
- func (s *ContivshimManager) PortForward(ctx context.Context, req *kubeapi.PortForwardRequest) (*kubeapi.PortForwardResponse, error)
- func (s *ContivshimManager) PullImage(ctx context.Context, req *kubeapi.PullImageRequest) (*kubeapi.PullImageResponse, error)
- func (s *ContivshimManager) RemoveContainer(ctx context.Context, req *kubeapi.RemoveContainerRequest) (*kubeapi.RemoveContainerResponse, error)
- func (s *ContivshimManager) RemoveImage(ctx context.Context, req *kubeapi.RemoveImageRequest) (*kubeapi.RemoveImageResponse, error)
- func (s *ContivshimManager) RemovePodSandbox(ctx context.Context, req *kubeapi.RemovePodSandboxRequest) (*kubeapi.RemovePodSandboxResponse, error)
- func (s *ContivshimManager) RunPodSandbox(ctx context.Context, req *kubeapi.RunPodSandboxRequest) (*kubeapi.RunPodSandboxResponse, error)
- func (s *ContivshimManager) Serve(addr string) error
- func (s *ContivshimManager) StartContainer(ctx context.Context, req *kubeapi.StartContainerRequest) (*kubeapi.StartContainerResponse, error)
- func (s *ContivshimManager) Status(ctx context.Context, req *kubeapi.StatusRequest) (*kubeapi.StatusResponse, error)
- func (s *ContivshimManager) StopContainer(ctx context.Context, req *kubeapi.StopContainerRequest) (*kubeapi.StopContainerResponse, error)
- func (s *ContivshimManager) StopPodSandbox(ctx context.Context, req *kubeapi.StopPodSandboxRequest) (*kubeapi.StopPodSandboxResponse, error)
- func (s *ContivshimManager) UpdateContainerResources(ctx context.Context, req *kubeapi.UpdateContainerResourcesRequest) (*kubeapi.UpdateContainerResourcesResponse, error)
- func (s *ContivshimManager) UpdateRuntimeConfig(ctx context.Context, req *kubeapi.UpdateRuntimeConfigRequest) (*kubeapi.UpdateRuntimeConfigResponse, error)
- func (s *ContivshimManager) Version(ctx context.Context, req *kubeapi.VersionRequest) (*kubeapi.VersionResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ContivshimManager ¶
type ContivshimManager struct {
// contains filtered or unexported fields
}
ContivshimManager serves the kubelet runtime gRPC api which will be consumed by kubelet
func NewContivshimManager ¶
func NewContivshimManager( etcdEndpoint *string, dockerRuntimeService criruntime.RuntimeService, dockerImageService criruntime.ImageManagerService, ) (*ContivshimManager, error)
NewContivshimManager creates a new ContivshimManager
func (*ContivshimManager) Attach ¶
func (s *ContivshimManager) Attach(ctx context.Context, req *kubeapi.AttachRequest) (*kubeapi.AttachResponse, error)
Attach prepares a streaming endpoint to attach to a running container.
func (*ContivshimManager) ContainerStats ¶
func (s *ContivshimManager) ContainerStats(ctx context.Context, req *kubeapi.ContainerStatsRequest) (*kubeapi.ContainerStatsResponse, error)
ContainerStats returns information of the container filesystem.
func (*ContivshimManager) ContainerStatus ¶
func (s *ContivshimManager) ContainerStatus(ctx context.Context, req *kubeapi.ContainerStatusRequest) (*kubeapi.ContainerStatusResponse, error)
ContainerStatus returns the container status.
func (*ContivshimManager) CreateContainer ¶
func (s *ContivshimManager) CreateContainer(ctx context.Context, req *kubeapi.CreateContainerRequest) (*kubeapi.CreateContainerResponse, error)
CreateContainer creates a new container in specified PodSandbox
func (*ContivshimManager) Exec ¶
func (s *ContivshimManager) Exec(ctx context.Context, req *kubeapi.ExecRequest) (*kubeapi.ExecResponse, error)
Exec prepares a streaming endpoint to execute a command in the container.
func (*ContivshimManager) ExecSync ¶
func (s *ContivshimManager) ExecSync(ctx context.Context, req *kubeapi.ExecSyncRequest) (*kubeapi.ExecSyncResponse, error)
ExecSync runs a command in a container synchronously.
func (*ContivshimManager) ImageFsInfo ¶
func (s *ContivshimManager) ImageFsInfo(ctx context.Context, req *kubeapi.ImageFsInfoRequest) (*kubeapi.ImageFsInfoResponse, error)
ImageFsInfo returns information of the filesystem that is used to store images.
func (*ContivshimManager) ImageStatus ¶
func (s *ContivshimManager) ImageStatus(ctx context.Context, req *kubeapi.ImageStatusRequest) (*kubeapi.ImageStatusResponse, error)
ImageStatus returns the status of the image.
func (*ContivshimManager) ListContainerStats ¶
func (s *ContivshimManager) ListContainerStats(ctx context.Context, req *kubeapi.ListContainerStatsRequest) (*kubeapi.ListContainerStatsResponse, error)
ListContainerStats is this
func (*ContivshimManager) ListContainers ¶
func (s *ContivshimManager) ListContainers(ctx context.Context, req *kubeapi.ListContainersRequest) (*kubeapi.ListContainersResponse, error)
ListContainers lists all containers by filters.
func (*ContivshimManager) ListImages ¶
func (s *ContivshimManager) ListImages(ctx context.Context, req *kubeapi.ListImagesRequest) (*kubeapi.ListImagesResponse, error)
ListImages lists existing images.
func (*ContivshimManager) ListPodSandbox ¶
func (s *ContivshimManager) ListPodSandbox(ctx context.Context, req *kubeapi.ListPodSandboxRequest) (*kubeapi.ListPodSandboxResponse, error)
ListPodSandbox returns a list of SandBox.
func (*ContivshimManager) PodSandboxStatus ¶
func (s *ContivshimManager) PodSandboxStatus(ctx context.Context, req *kubeapi.PodSandboxStatusRequest) (*kubeapi.PodSandboxStatusResponse, error)
PodSandboxStatus returns the Status of the PodSandbox.
func (*ContivshimManager) PortForward ¶
func (s *ContivshimManager) PortForward(ctx context.Context, req *kubeapi.PortForwardRequest) (*kubeapi.PortForwardResponse, error)
PortForward prepares a streaming endpoint to forward ports from a PodSandbox.
func (*ContivshimManager) PullImage ¶
func (s *ContivshimManager) PullImage(ctx context.Context, req *kubeapi.PullImageRequest) (*kubeapi.PullImageResponse, error)
PullImage pulls a image with authentication config.
func (*ContivshimManager) RemoveContainer ¶
func (s *ContivshimManager) RemoveContainer(ctx context.Context, req *kubeapi.RemoveContainerRequest) (*kubeapi.RemoveContainerResponse, error)
RemoveContainer removes the container.
func (*ContivshimManager) RemoveImage ¶
func (s *ContivshimManager) RemoveImage(ctx context.Context, req *kubeapi.RemoveImageRequest) (*kubeapi.RemoveImageResponse, error)
RemoveImage removes the image.
func (*ContivshimManager) RemovePodSandbox ¶
func (s *ContivshimManager) RemovePodSandbox(ctx context.Context, req *kubeapi.RemovePodSandboxRequest) (*kubeapi.RemovePodSandboxResponse, error)
RemovePodSandbox deletes the sandbox.
func (*ContivshimManager) RunPodSandbox ¶
func (s *ContivshimManager) RunPodSandbox(ctx context.Context, req *kubeapi.RunPodSandboxRequest) (*kubeapi.RunPodSandboxResponse, error)
RunPodSandbox creates and start a Pod.
func (*ContivshimManager) Serve ¶
func (s *ContivshimManager) Serve(addr string) error
Serve starts gRPC server at unix://addr
func (*ContivshimManager) StartContainer ¶
func (s *ContivshimManager) StartContainer(ctx context.Context, req *kubeapi.StartContainerRequest) (*kubeapi.StartContainerResponse, error)
StartContainer starts the container.
func (*ContivshimManager) Status ¶
func (s *ContivshimManager) Status(ctx context.Context, req *kubeapi.StatusRequest) (*kubeapi.StatusResponse, error)
Status returns the status of the criruntime.
func (*ContivshimManager) StopContainer ¶
func (s *ContivshimManager) StopContainer(ctx context.Context, req *kubeapi.StopContainerRequest) (*kubeapi.StopContainerResponse, error)
StopContainer stops a running container with a grace period (i.e. timeout).
func (*ContivshimManager) StopPodSandbox ¶
func (s *ContivshimManager) StopPodSandbox(ctx context.Context, req *kubeapi.StopPodSandboxRequest) (*kubeapi.StopPodSandboxResponse, error)
StopPodSandbox stops the sandbox.
func (*ContivshimManager) UpdateContainerResources ¶
func (s *ContivshimManager) UpdateContainerResources( ctx context.Context, req *kubeapi.UpdateContainerResourcesRequest, ) (*kubeapi.UpdateContainerResourcesResponse, error)
UpdateContainerResources is this
func (*ContivshimManager) UpdateRuntimeConfig ¶
func (s *ContivshimManager) UpdateRuntimeConfig(ctx context.Context, req *kubeapi.UpdateRuntimeConfigRequest) (*kubeapi.UpdateRuntimeConfigResponse, error)
UpdateRuntimeConfig updates runtime configuration if specified
func (*ContivshimManager) Version ¶
func (s *ContivshimManager) Version(ctx context.Context, req *kubeapi.VersionRequest) (*kubeapi.VersionResponse, error)
Version returns the runtime name, runtime version and runtime API version.