package remote

import "k8s.io/kubernetes/pkg/kubelet/remote"

Package remote containers gRPC implementation of internalApi.RuntimeService and internalApi.ImageManagerService.

Index ¶

• func NewRemoteImageService(addr string, connectionTimout time.Duration) (internalApi.ImageManagerService, error)
• func NewRemoteRuntimeService(addr string, connectionTimout time.Duration) (internalApi.RuntimeService, error)
• type RemoteImageService
• func (r *RemoteImageService) ImageStatus(image *runtimeApi.ImageSpec) (*runtimeApi.Image, error)
• func (r *RemoteImageService) ListImages(filter *runtimeApi.ImageFilter) ([]*runtimeApi.Image, error)
• func (r *RemoteImageService) PullImage(image *runtimeApi.ImageSpec, auth *runtimeApi.AuthConfig) error
• func (r *RemoteImageService) RemoveImage(image *runtimeApi.ImageSpec) error
• type RemoteRuntimeService
• func (r *RemoteRuntimeService) ContainerStatus(containerID string) (*runtimeApi.ContainerStatus, error)
• func (r *RemoteRuntimeService) CreateContainer(podSandBoxID string, config *runtimeApi.ContainerConfig, sandboxConfig *runtimeApi.PodSandboxConfig) (string, error)
• func (r *RemoteRuntimeService) CreatePodSandbox(config *runtimeApi.PodSandboxConfig) (string, error)
• func (r *RemoteRuntimeService) Exec(containerID string, cmd []string, tty bool, stdin io.Reader, stdout, stderr io.WriteCloser) error
• func (r *RemoteRuntimeService) ListContainers(filter *runtimeApi.ContainerFilter) ([]*runtimeApi.Container, error)
• func (r *RemoteRuntimeService) ListPodSandbox(filter *runtimeApi.PodSandboxFilter) ([]*runtimeApi.PodSandbox, error)
• func (r *RemoteRuntimeService) PodSandboxStatus(podSandBoxID string) (*runtimeApi.PodSandboxStatus, error)
• func (r *RemoteRuntimeService) RemoveContainer(containerID string) error
• func (r *RemoteRuntimeService) RemovePodSandbox(podSandBoxID string) error
• func (r *RemoteRuntimeService) StartContainer(containerID string) error
• func (r *RemoteRuntimeService) StopContainer(containerID string, timeout int64) error
• func (r *RemoteRuntimeService) StopPodSandbox(podSandBoxID string) error
• func (r *RemoteRuntimeService) Version(apiVersion string) (*runtimeApi.VersionResponse, error)

Functions ¶

func NewRemoteImageService ¶

func NewRemoteImageService(addr string, connectionTimout time.Duration) (internalApi.ImageManagerService, error)

NewRemoteImageService creates a new internalApi.ImageManagerService.

func NewRemoteRuntimeService ¶

func NewRemoteRuntimeService(addr string, connectionTimout time.Duration) (internalApi.RuntimeService, error)

NewRemoteRuntimeService creates a new internalApi.RuntimeService.

Types ¶

type RemoteImageService ¶

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

RemoteImageService is a gRPC implementation of internalApi.ImageManagerService.

func (*RemoteImageService) ImageStatus ¶

func (r *RemoteImageService) ImageStatus(image *runtimeApi.ImageSpec) (*runtimeApi.Image, error)

ImageStatus returns the status of the image.

func (*RemoteImageService) ListImages ¶

func (r *RemoteImageService) ListImages(filter *runtimeApi.ImageFilter) ([]*runtimeApi.Image, error)

ListImages lists available images.

func (*RemoteImageService) PullImage ¶

func (r *RemoteImageService) PullImage(image *runtimeApi.ImageSpec, auth *runtimeApi.AuthConfig) error

PullImage pulls an image with authentication config.

func (*RemoteImageService) RemoveImage ¶

func (r *RemoteImageService) RemoveImage(image *runtimeApi.ImageSpec) error

RemoveImage removes the image.

type RemoteRuntimeService ¶

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

RemoteRuntimeService is a gRPC implementation of internalApi.RuntimeService.

func (*RemoteRuntimeService) ContainerStatus ¶

func (r *RemoteRuntimeService) ContainerStatus(containerID string) (*runtimeApi.ContainerStatus, error)

ContainerStatus returns the container status.

func (*RemoteRuntimeService) CreateContainer ¶

func (r *RemoteRuntimeService) CreateContainer(podSandBoxID string, config *runtimeApi.ContainerConfig, sandboxConfig *runtimeApi.PodSandboxConfig) (string, error)

CreateContainer creates a new container in the specified PodSandbox.

func (*RemoteRuntimeService) CreatePodSandbox ¶

func (r *RemoteRuntimeService) CreatePodSandbox(config *runtimeApi.PodSandboxConfig) (string, error)

CreatePodSandbox creates a pod-level sandbox.

func (*RemoteRuntimeService) Exec ¶

func (r *RemoteRuntimeService) Exec(containerID string, cmd []string, tty bool, stdin io.Reader, stdout, stderr io.WriteCloser) error

Exec executes a command in the container. TODO: support terminal resizing for exec, refer https://github.com/kubernetes/kubernetes/issues/29579.

func (*RemoteRuntimeService) ListContainers ¶

func (r *RemoteRuntimeService) ListContainers(filter *runtimeApi.ContainerFilter) ([]*runtimeApi.Container, error)

ListContainers lists containers by filters.

func (*RemoteRuntimeService) ListPodSandbox ¶

func (r *RemoteRuntimeService) ListPodSandbox(filter *runtimeApi.PodSandboxFilter) ([]*runtimeApi.PodSandbox, error)

ListPodSandbox returns a list of PodSandboxes.

func (*RemoteRuntimeService) PodSandboxStatus ¶

func (r *RemoteRuntimeService) PodSandboxStatus(podSandBoxID string) (*runtimeApi.PodSandboxStatus, error)

PodSandboxStatus returns the status of the PodSandbox.

func (*RemoteRuntimeService) RemoveContainer ¶

func (r *RemoteRuntimeService) RemoveContainer(containerID string) error

RemoveContainer removes the container. If the container is running, the container should be forced to removal.

func (*RemoteRuntimeService) RemovePodSandbox ¶

func (r *RemoteRuntimeService) RemovePodSandbox(podSandBoxID string) error

RemovePodSandbox removes the sandbox. If there are any containers in the sandbox, they should be forcibly removed.

func (*RemoteRuntimeService) StartContainer ¶

func (r *RemoteRuntimeService) StartContainer(containerID string) error

StartContainer starts the container.

func (*RemoteRuntimeService) StopContainer ¶

func (r *RemoteRuntimeService) StopContainer(containerID string, timeout int64) error

StopContainer stops a running container with a grace period (i.e., timeout).

func (*RemoteRuntimeService) StopPodSandbox ¶

func (r *RemoteRuntimeService) StopPodSandbox(podSandBoxID string) error

StopPodSandbox stops the sandbox. If there are any running containers in the sandbox, they should be forced to termination.

func (*RemoteRuntimeService) Version ¶

func (r *RemoteRuntimeService) Version(apiVersion string) (*runtimeApi.VersionResponse, error)

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

Source Files ¶

doc.go remote_image.go remote_runtime.go utils.go