kubernetes: k8s.io/kubernetes/pkg/kubelet/remote Index | Files | Directories

package remote

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

Package remote contains gRPC implementation of internalapi.RuntimeService and internalapi.ImageManagerService.

Index

Package Files

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

func NewRemoteImageService Uses

func NewRemoteImageService(endpoint string, connectionTimeout time.Duration) (internalapi.ImageManagerService, error)

NewRemoteImageService creates a new internalapi.ImageManagerService.

func NewRemoteRuntimeService Uses

func NewRemoteRuntimeService(endpoint string, connectionTimeout time.Duration) (internalapi.RuntimeService, error)

NewRemoteRuntimeService creates a new internalapi.RuntimeService.

type RemoteImageService Uses

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

RemoteImageService is a gRPC implementation of internalapi.ImageManagerService.

func (*RemoteImageService) ImageFsInfo Uses

func (r *RemoteImageService) ImageFsInfo() ([]*runtimeapi.FilesystemUsage, error)

ImageFsInfo returns information of the filesystem that is used to store images.

func (*RemoteImageService) ImageStatus Uses

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

ImageStatus returns the status of the image.

func (*RemoteImageService) ListImages Uses

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

ListImages lists available images.

func (*RemoteImageService) PullImage Uses

func (r *RemoteImageService) PullImage(image *runtimeapi.ImageSpec, auth *runtimeapi.AuthConfig, podSandboxConfig *runtimeapi.PodSandboxConfig) (string, error)

PullImage pulls an image with authentication config.

func (*RemoteImageService) RemoveImage Uses

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

RemoveImage removes the image.

type RemoteRuntimeService Uses

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

RemoteRuntimeService is a gRPC implementation of internalapi.RuntimeService.

func (*RemoteRuntimeService) Attach Uses

func (r *RemoteRuntimeService) Attach(req *runtimeapi.AttachRequest) (*runtimeapi.AttachResponse, error)

Attach prepares a streaming endpoint to attach to a running container, and returns the address.

func (*RemoteRuntimeService) ContainerStats Uses

func (r *RemoteRuntimeService) ContainerStats(containerID string) (*runtimeapi.ContainerStats, error)

ContainerStats returns the stats of the container.

func (*RemoteRuntimeService) ContainerStatus Uses

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

ContainerStatus returns the container status.

func (*RemoteRuntimeService) CreateContainer Uses

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) Exec Uses

func (r *RemoteRuntimeService) Exec(req *runtimeapi.ExecRequest) (*runtimeapi.ExecResponse, error)

Exec prepares a streaming endpoint to execute a command in the container, and returns the address.

func (*RemoteRuntimeService) ExecSync Uses

func (r *RemoteRuntimeService) ExecSync(containerID string, cmd []string, timeout time.Duration) (stdout []byte, stderr []byte, err error)

ExecSync executes a command in the container, and returns the stdout output. If command exits with a non-zero exit code, an error is returned.

func (*RemoteRuntimeService) ListContainerStats Uses

func (r *RemoteRuntimeService) ListContainerStats(filter *runtimeapi.ContainerStatsFilter) ([]*runtimeapi.ContainerStats, error)

func (*RemoteRuntimeService) ListContainers Uses

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

ListContainers lists containers by filters.

func (*RemoteRuntimeService) ListPodSandbox Uses

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

ListPodSandbox returns a list of PodSandboxes.

func (*RemoteRuntimeService) PodSandboxStatus Uses

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

PodSandboxStatus returns the status of the PodSandbox.

func (*RemoteRuntimeService) PortForward Uses

func (r *RemoteRuntimeService) PortForward(req *runtimeapi.PortForwardRequest) (*runtimeapi.PortForwardResponse, error)

PortForward prepares a streaming endpoint to forward ports from a PodSandbox, and returns the address.

func (*RemoteRuntimeService) RemoveContainer Uses

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 Uses

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) ReopenContainerLog Uses

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

func (*RemoteRuntimeService) RunPodSandbox Uses

func (r *RemoteRuntimeService) RunPodSandbox(config *runtimeapi.PodSandboxConfig, runtimeHandler string) (string, error)

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

func (*RemoteRuntimeService) StartContainer Uses

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

StartContainer starts the container.

func (*RemoteRuntimeService) Status Uses

func (r *RemoteRuntimeService) Status() (*runtimeapi.RuntimeStatus, error)

Status returns the status of the runtime.

func (*RemoteRuntimeService) StopContainer Uses

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

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

func (*RemoteRuntimeService) StopPodSandbox Uses

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) UpdateContainerResources Uses

func (r *RemoteRuntimeService) UpdateContainerResources(containerID string, resources *runtimeapi.LinuxContainerResources) error

UpdateContainerResources updates a containers resource config

func (*RemoteRuntimeService) UpdateRuntimeConfig Uses

func (r *RemoteRuntimeService) UpdateRuntimeConfig(runtimeConfig *runtimeapi.RuntimeConfig) error

UpdateRuntimeConfig updates the config of a runtime service. The only update payload currently supported is the pod CIDR assigned to a node, and the runtime service just proxies it down to the network plugin.

func (*RemoteRuntimeService) Version Uses

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

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

Directories

PathSynopsis
fakePackage fake containers a fake gRPC implementation of internalapi.RuntimeService and internalapi.ImageManagerService.

Package remote imports 12 packages (graph) and is imported by 27 packages. Updated 2019-04-11. Refresh now. Tools for package owners.