kuberuntime

Documentation

Overview

Package kuberuntime contains an implementation of kubecontainer.Runtime using the interface in pkg/kubelet/api.

Index

• Variables
• func NewContainerGC(client internalApi.RuntimeService, podGetter podGetter, ...) *containerGC
• func NewFakeKubeRuntimeManager(runtimeService internalApi.RuntimeService, ...) (*kubeGenericRuntimeManager, error)
• func NewInstrumentedImageManagerService(service internalApi.ImageManagerService) internalApi.ImageManagerService
• func NewInstrumentedRuntimeService(service internalApi.RuntimeService) internalApi.RuntimeService
• func ReadLogs(path string, apiOpts *api.PodLogOptions, stdout, stderr io.Writer) error
• type KubeGenericRuntime
  • func NewKubeGenericRuntimeManager(recorder record.EventRecorder, livenessManager proberesults.Manager, ...) (KubeGenericRuntime, error)

Variables

var (
	// ErrVersionNotSupported is returned when the api version of runtime interface is not supported
	ErrVersionNotSupported = errors.New("Runtime api version is not supported")
)

Functions

func NewContainerGC

func NewContainerGC(client internalApi.RuntimeService, podGetter podGetter, manager *kubeGenericRuntimeManager) *containerGC

NewContainerGC creates a new containerGC.

func NewFakeKubeRuntimeManager

func NewFakeKubeRuntimeManager(runtimeService internalApi.RuntimeService, imageService internalApi.ImageManagerService, machineInfo *cadvisorapi.MachineInfo, networkPlugin network.NetworkPlugin, osInterface kubecontainer.OSInterface) (*kubeGenericRuntimeManager, error)

func NewInstrumentedImageManagerService

func NewInstrumentedImageManagerService(service internalApi.ImageManagerService) internalApi.ImageManagerService

Creates an instrumented ImageManagerService from an existing ImageManagerService.

func NewInstrumentedRuntimeService

func NewInstrumentedRuntimeService(service internalApi.RuntimeService) internalApi.RuntimeService

Creates an instrumented RuntimeInterface from an existing RuntimeService.

func ReadLogs

func ReadLogs(path string, apiOpts *api.PodLogOptions, stdout, stderr io.Writer) error

ReadLogs read the container log and redirect into stdout and stderr.

Types

type KubeGenericRuntime

type KubeGenericRuntime interface {
	kubecontainer.Runtime
	kubecontainer.IndirectStreamingRuntime
	kubecontainer.ContainerCommandRunner
	// TODO(timstclair): Remove this once the indirect path is fully functional.
	kubecontainer.DirectStreamingRuntime
}

func NewKubeGenericRuntimeManager

func NewKubeGenericRuntimeManager(
	recorder record.EventRecorder,
	livenessManager proberesults.Manager,
	containerRefManager *kubecontainer.RefManager,
	machineInfo *cadvisorapi.MachineInfo,
	podGetter podGetter,
	osInterface kubecontainer.OSInterface,
	networkPlugin network.NetworkPlugin,
	runtimeHelper kubecontainer.RuntimeHelper,
	httpClient types.HttpGetter,
	imageBackOff *flowcontrol.Backoff,
	serializeImagePulls bool,
	imagePullQPS float32,
	imagePullBurst int,
	cpuCFSQuota bool,
	runtimeService internalApi.RuntimeService,
	imageService internalApi.ImageManagerService,
) (KubeGenericRuntime, error)

NewKubeGenericRuntimeManager creates a new kubeGenericRuntimeManager