cri

package
v0.0.0-...-e507620 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 7, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LibvirtKubeletService 

type LibvirtKubeletService struct {
	// contains filtered or unexported fields
}

func NewService 

func NewService(kubeletAddr string, libvirtURI string) (*LibvirtKubeletService, error)

func (*LibvirtKubeletService) Attach 

func (s *LibvirtKubeletService) Attach(ctx context.Context, req *runtime.AttachRequest) (*runtime.AttachResponse, error)

Attach prepares a streaming endpoint to attach to a running container.

func (*LibvirtKubeletService) ContainerStatus 

func (s *LibvirtKubeletService) ContainerStatus(ctx context.Context, req *runtime.ContainerStatusRequest) (*runtime.ContainerStatusResponse, error)

ContainerStatus returns status of the container.

func (*LibvirtKubeletService) CreateContainer 

func (s *LibvirtKubeletService) CreateContainer(ctx context.Context, req *runtime.CreateContainerRequest) (*runtime.CreateContainerResponse, error)

CreateContainer creates a new container in specified PodSandbox

func (*LibvirtKubeletService) Exec 

func (s *LibvirtKubeletService) Exec(ctx context.Context, req *runtime.ExecRequest) (*runtime.ExecResponse, error)

Exec prepares a streaming endpoint to execute a command in the container.

func (*LibvirtKubeletService) ExecSync 

func (s *LibvirtKubeletService) ExecSync(ctx context.Context, req *runtime.ExecSyncRequest) (*runtime.ExecSyncResponse, error)

ExecSync runs a command in a container synchronously.

func (*LibvirtKubeletService) ImageStatus 

func (s *LibvirtKubeletService) ImageStatus(ctx context.Context, req *runtime.ImageStatusRequest) (*runtime.ImageStatusResponse, error)

ImageStatus returns the status of the image. If the image is not present, returns nil.

func (*LibvirtKubeletService) ListContainers 

func (s *LibvirtKubeletService) ListContainers(ctx context.Context, req *runtime.ListContainersRequest) (*runtime.ListContainersResponse, error)

ListContainers lists all containers by filters.

func (*LibvirtKubeletService) ListImages 

func (s *LibvirtKubeletService) ListImages(ctx context.Context, req *runtime.ListImagesRequest) (*runtime.ListImagesResponse, error)

ListImages lists existing images.

func (*LibvirtKubeletService) ListPodSandbox 

func (s *LibvirtKubeletService) ListPodSandbox(ctx context.Context, req *runtime.ListPodSandboxRequest) (*runtime.ListPodSandboxResponse, error)

ListPodSandbox returns a list of PodSandboxes.

func (*LibvirtKubeletService) PodSandboxStatus 

func (s *LibvirtKubeletService) PodSandboxStatus(ctx context.Context, req *runtime.PodSandboxStatusRequest) (*runtime.PodSandboxStatusResponse, error)

PodSandboxStatus returns the status of the PodSandbox.

func (*LibvirtKubeletService) PortForward 

func (s *LibvirtKubeletService) PortForward(ctx context.Context, req *runtime.PortForwardRequest) (*runtime.PortForwardResponse, error)

PortForward prepares a streaming endpoint to forward ports from a PodSandbox.

func (*LibvirtKubeletService) PullImage 

func (s *LibvirtKubeletService) PullImage(ctx context.Context, req *runtime.PullImageRequest) (*runtime.PullImageResponse, error)

PullImage pulls an image with authentication config.

func (*LibvirtKubeletService) RemoveContainer 

func (s *LibvirtKubeletService) RemoveContainer(ctx context.Context, req *runtime.RemoveContainerRequest) (*runtime.RemoveContainerResponse, 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 (*LibvirtKubeletService) RemoveImage 

func (s *LibvirtKubeletService) RemoveImage(ctx context.Context, req *runtime.RemoveImageRequest) (*runtime.RemoveImageResponse, error)

RemoveImage removes the image. This call is idempotent, and must not return an error if the image has already been removed.

func (*LibvirtKubeletService) RemovePodSandbox 

func (s *LibvirtKubeletService) RemovePodSandbox(ctx context.Context, req *runtime.RemovePodSandboxRequest) (*runtime.RemovePodSandboxResponse, 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 (*LibvirtKubeletService) Run 

func (s *LibvirtKubeletService) Run() error

func (*LibvirtKubeletService) RunPodSandbox 

func (s *LibvirtKubeletService) RunPodSandbox(ctx context.Context, req *runtime.RunPodSandboxRequest) (*runtime.RunPodSandboxResponse, error)

RunPodSandbox creates and starts a pod-level sandbox. Runtimes must ensure the sandbox is in the ready state on success.

func (*LibvirtKubeletService) StartContainer 

func (s *LibvirtKubeletService) StartContainer(ctx context.Context, req *runtime.StartContainerRequest) (*runtime.StartContainerResponse, error)

StartContainer starts the container.

func (*LibvirtKubeletService) Status 

func (s *LibvirtKubeletService) Status(ctx context.Context, req *runtime.StatusRequest) (*runtime.StatusResponse, error)

Status returns the status of the runtime.

func (*LibvirtKubeletService) StopContainer 

func (s *LibvirtKubeletService) StopContainer(ctx context.Context, req *runtime.StopContainerRequest) (*runtime.StopContainerResponse, 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. TODO: what must the runtime do after the grace period is reached?

func (*LibvirtKubeletService) StopPodSandbox 

func (s *LibvirtKubeletService) StopPodSandbox(ctx context.Context, req *runtime.StopPodSandboxRequest) (*runtime.StopPodSandboxResponse, 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. This call is idempotent, and must not return an error if all relevant resources have already been reclaimed. kubelet will call StopPodSandbox at least once before calling RemovePodSandbox. It will also attempt to reclaim resources eagerly, as soon as a sandbox is not needed. Hence, multiple StopPodSandbox calls are expected.

func (*LibvirtKubeletService) UpdateRuntimeConfig 

func (s *LibvirtKubeletService) UpdateRuntimeConfig(ctx context.Context, req *runtime.UpdateRuntimeConfigRequest) (*runtime.UpdateRuntimeConfigResponse, error)

UpdateRuntimeConfig updates the runtime configuration based on the given request.

func (*LibvirtKubeletService) Version 

func (s *LibvirtKubeletService) Version(ctx context.Context, req *runtime.VersionRequest) (*runtime.VersionResponse, error)

Version returns the runtime name, runtime version, and runtime API version.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.