▽

Package kuberuntime

Variables

var (
    // ErrCreateContainerConfig - failed to create container config
    ErrCreateContainerConfig = errors.New("CreateContainerConfigError")
    // ErrPreCreateHook - failed to execute PreCreateHook
    ErrPreCreateHook = errors.New("PreCreateHookError")
    // ErrCreateContainer - failed to create container
    ErrCreateContainer = errors.New("CreateContainerError")
    // ErrPreStartHook - failed to execute PreStartHook
    ErrPreStartHook = errors.New("PreStartHookError")
    // ErrPostStartHook - failed to execute PostStartHook
    ErrPostStartHook = errors.New("PostStartHookError")
)

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

func BuildContainerLogsDirectory ¶

func BuildContainerLogsDirectory(podLogsDir, podNamespace, podName string, podUID types.UID, containerName string) string

BuildContainerLogsDirectory builds absolute log directory path for a container in pod.

func BuildPodLogsDirectory ¶

func BuildPodLogsDirectory(podLogsDir, podNamespace, podName string, podUID types.UID) string

BuildPodLogsDirectory builds absolute log directory path for a pod sandbox.

func GetHugepageLimitsFromResources ¶

func GetHugepageLimitsFromResources(resources v1.ResourceRequirements) []*runtimeapi.HugepageLimit

GetHugepageLimitsFromResources returns limits of each hugepages from resources.

type KubeGenericRuntime ¶

KubeGenericRuntime is a interface contains interfaces for container runtime and command.

type KubeGenericRuntime interface {
    kubecontainer.Runtime
    kubecontainer.StreamingRuntime
    kubecontainer.CommandRunner
}

func NewKubeGenericRuntimeManager ¶

func NewKubeGenericRuntimeManager(
    recorder record.EventRecorder,
    livenessManager proberesults.Manager,
    readinessManager proberesults.Manager,
    startupManager proberesults.Manager,
    rootDirectory string,
    podLogsDirectory string,
    machineInfo *cadvisorapi.MachineInfo,
    podStateProvider podStateProvider,
    osInterface kubecontainer.OSInterface,
    runtimeHelper kubecontainer.RuntimeHelper,
    insecureContainerLifecycleHTTPClient types.HTTPDoer,
    imageBackOff *flowcontrol.Backoff,
    serializeImagePulls bool,
    maxParallelImagePulls *int32,
    imagePullQPS float32,
    imagePullBurst int,
    imageCredentialProviderConfigFile string,
    imageCredentialProviderBinDir string,
    cpuCFSQuota bool,
    cpuCFSQuotaPeriod metav1.Duration,
    runtimeService internalapi.RuntimeService,
    imageService internalapi.ImageManagerService,
    containerManager cm.ContainerManager,
    logManager logs.ContainerLogManager,
    runtimeClassManager *runtimeclass.Manager,
    seccompDefault bool,
    memorySwapBehavior string,
    getNodeAllocatable func() v1.ResourceList,
    memoryThrottlingFactor float64,
    podPullingTimeRecorder images.ImagePodPullingTimeRecorder,
    tracerProvider trace.TracerProvider,
) (KubeGenericRuntime, error)

NewKubeGenericRuntimeManager creates a new kubeGenericRuntimeManager

Subdirectories