util

Documentation

Overview

Package util holds utility functions.

Index

• Variables
• func CreateListener(endpoint string) (net.Listener, error)
• func FromApiserverCache(opts *metav1.GetOptions)
• func GetAddressAndDialer(endpoint string) (string, func(ctx context.Context, addr string) (net.Conn, error), error)
• 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 LocalEndpoint(path, file string) (string, error)
• func LockAndCheckSubPath(volumePath, subPath string) ([]uintptr, error)
• func SetNodeOwnerFunc(c clientset.Interface, nodeName string) func(lease *coordinationv1.Lease) error
• func UnlockPath(fileHandles []uintptr)
• type NodeStartupLatencyTracker
  • func NewNodeStartupLatencyTracker() NodeStartupLatencyTracker
• type PodStartupLatencyTracker
  • func NewPodStartupLatencyTracker() PodStartupLatencyTracker

Variables

var IsUnixDomainSocket = filesystem.IsUnixDomainSocket

Functions

func CreateListener

func CreateListener(endpoint string) (net.Listener, error)

CreateListener creates a listener on the specified endpoint.

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 GetAddressAndDialer

func GetAddressAndDialer(endpoint string) (string, func(ctx context.Context, addr string) (net.Conn, error), error)

GetAddressAndDialer returns the address parsed from the given endpoint and a context dialer.

func GetBootTime

func GetBootTime() (time.Time, error)

GetBootTime empty implementation

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 LocalEndpoint

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

LocalEndpoint empty implementation

func LockAndCheckSubPath

func LockAndCheckSubPath(volumePath, subPath string) ([]uintptr, error)

LockAndCheckSubPath empty implementation

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

func UnlockPath

func UnlockPath(fileHandles []uintptr)

UnlockPath empty implementation

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