package util

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

Package util holds utility functions.

Index ¶

• Variables
• func FromApiserverCache(opts *metav1.GetOptions)
• func GetBootTime() (time.Time, error)
• func GetContainerByIndex(containers []v1.Container, statuses []v1.ContainerStatus, idx int) (v1.Container, bool)
• func GetNodenameForKernel(hostname string, hostDomainName string, setHostnameAsFQDN *bool) (string, error)
• func IsCgroup2UnifiedMode() bool
• func LocalEndpoint(path, file string) (string, error)
• func NormalizePath(path string) string
• func SetNodeOwnerFunc(c clientset.Interface, nodeName string) func(lease *coordinationv1.Lease) error
• type NodeStartupLatencyTracker
• func NewNodeStartupLatencyTracker() NodeStartupLatencyTracker
• type PodStartupLatencyTracker
• func NewPodStartupLatencyTracker() PodStartupLatencyTracker

Variables ¶

var IsUnixDomainSocket = filesystem.IsUnixDomainSocket

Functions ¶

func FromApiserverCache ¶

func FromApiserverCache(opts *metav1.GetOptions)

FromApiserverCache modifies <opts> so that the GET request will be served from apiserver cache instead of from etcd.

func GetBootTime ¶

func GetBootTime() (time.Time, error)

GetBootTime returns the time at which the machine was started, truncated to the nearest second

func GetContainerByIndex ¶

func GetContainerByIndex(containers []v1.Container, statuses []v1.ContainerStatus, idx int) (v1.Container, bool)

GetContainerByIndex validates and extracts the container at index "idx" from "containers" with respect to "statuses". It returns true if the container is valid, else returns false.

func GetNodenameForKernel ¶

func GetNodenameForKernel(hostname string, hostDomainName string, setHostnameAsFQDN *bool) (string, error)

GetNodenameForKernel gets hostname value to set in the hostname field (the nodename field of struct utsname) of the pod.

func IsCgroup2UnifiedMode ¶

func IsCgroup2UnifiedMode() bool

IsCgroup2UnifiedMode is a no-op for Windows for now

func LocalEndpoint ¶

func LocalEndpoint(path, file string) (string, error)

LocalEndpoint returns the full path to a named pipe at the given endpoint - unlike on unix, we can't use sockets.

func NormalizePath ¶

func NormalizePath(path string) string

NormalizePath converts FS paths returned by certain go frameworks (like fsnotify) to native Windows paths that can be passed to Windows specific code

func SetNodeOwnerFunc ¶

func SetNodeOwnerFunc(c clientset.Interface, nodeName string) func(lease *coordinationv1.Lease) error

SetNodeOwnerFunc helps construct a newLeasePostProcessFunc which sets a node OwnerReference to the given lease object

Types ¶

type NodeStartupLatencyTracker ¶

type NodeStartupLatencyTracker interface {
	// This function may be called across Kubelet restart.
	RecordAttemptRegisterNode()
	// This function should not be called across Kubelet restart.
	RecordRegisteredNewNode()
	// This function may be called across Kubelet restart.
	RecordNodeReady()
}

func NewNodeStartupLatencyTracker ¶

func NewNodeStartupLatencyTracker() NodeStartupLatencyTracker

type PodStartupLatencyTracker ¶

type PodStartupLatencyTracker interface {
	ObservedPodOnWatch(pod *v1.Pod, when time.Time)
	RecordImageStartedPulling(podUID types.UID)
	RecordImageFinishedPulling(podUID types.UID)
	RecordStatusUpdated(pod *v1.Pod)
	DeletePodStartupState(podUID types.UID)
}

PodStartupLatencyTracker records key moments for startup latency calculation, e.g. image pulling or pod observed running on watch.

func NewPodStartupLatencyTracker ¶

func NewPodStartupLatencyTracker() PodStartupLatencyTracker

NewPodStartupLatencyTracker creates an instance of PodStartupLatencyTracker

Source Files ¶

doc.go node_startup_latency_tracker.go nodelease.go pod_startup_latency_tracker.go util.go util_windows.go

Directories ¶