kuberuntime

package
v1.6.0-alpha.0 Latest Latest
Warning

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

Go to latest
Published: Nov 6, 2016 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

View Source
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 added in v1.5.0

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 added in v1.5.0

func NewInstrumentedImageManagerService(service internalApi.ImageManagerService) internalApi.ImageManagerService

Creates an instrumented ImageManagerService from an existing ImageManagerService.

func NewInstrumentedRuntimeService added in v1.5.0

func NewInstrumentedRuntimeService(service internalApi.RuntimeService) internalApi.RuntimeService

Creates an instrumented RuntimeInterface from an existing RuntimeService.

func ReadLogs added in v1.5.0

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 added in v1.5.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL