nodestatus

Documentation

Index

• Constants
• type Setter
  • func DaemonEndpoints(daemonEndpoints *v1.NodeDaemonEndpoints) Setter
  • func DiskPressureCondition(nowFunc func() time.Time, pressureFunc func() bool, ...) Setter
  • func GoRuntime() Setter
  • func Images(nodeStatusMaxImages int32, imageListFunc func() ([]kubecontainer.Image, error)) Setter
  • func MachineInfo(nodeName string, maxPods int, podsPerCore int, ...) Setter
  • func MemoryPressureCondition(nowFunc func() time.Time, pressureFunc func() bool, ...) Setter
  • func NodeAddress(nodeIP net.IP, validateNodeIPFunc func(net.IP) error, hostname string, ...) Setter
  • func OutOfDiskCondition(nowFunc func() time.Time, recordEventFunc func(eventType, event string)) Setter
  • func PIDPressureCondition(nowFunc func() time.Time, pressureFunc func() bool, ...) Setter
  • func ReadyCondition(nowFunc func() time.Time, runtimeErrorsFunc func() []string, ...) Setter
  • func VersionInfo(versionInfoFunc func() (*cadvisorapiv1.VersionInfo, error), ...) Setter
  • func VolumeLimits(volumePluginListFunc func() []volume.VolumePluginWithAttachLimits) Setter
  • func VolumesInUse(syncedFunc func() bool, volumesInUseFunc func() []v1.UniqueVolumeName) Setter

Constants

const (
	// MaxNamesPerImageInNodeStatus is max number of names
	// per image stored in the node status.
	MaxNamesPerImageInNodeStatus = 5
)

Types

type Setter

type Setter func(node *v1.Node) error

Setter modifies the node in-place, and returns an error if the modification failed. Setters may partially mutate the node before returning an error.

func DaemonEndpoints

func DaemonEndpoints(daemonEndpoints *v1.NodeDaemonEndpoints) Setter

DaemonEndpoints returns a Setter that updates the daemon endpoints on the node.

func DiskPressureCondition

func DiskPressureCondition(nowFunc func() time.Time,
	pressureFunc func() bool,
	recordEventFunc func(eventType, event string),
) Setter

DiskPressureCondition returns a Setter that updates the v1.NodeDiskPressure condition on the node.

func GoRuntime

func GoRuntime() Setter

GoRuntime returns a Setter that sets GOOS and GOARCH on the node.

func Images

func Images(nodeStatusMaxImages int32,
	imageListFunc func() ([]kubecontainer.Image, error),
) Setter

Images returns a Setter that updates the images on the node. imageListFunc is expected to return a list of images sorted in descending order by image size. nodeStatusMaxImages is ignored if set to -1.

func MachineInfo

func MachineInfo(nodeName string,
	maxPods int,
	podsPerCore int,
	machineInfoFunc func() (*cadvisorapiv1.MachineInfo, error),
	capacityFunc func() v1.ResourceList,
	devicePluginResourceCapacityFunc func() (v1.ResourceList, v1.ResourceList, []string),
	nodeAllocatableReservationFunc func() v1.ResourceList,
	recordEventFunc func(eventType, event, message string),
) Setter

MachineInfo returns a Setter that updates machine-related information on the node.

func MemoryPressureCondition

func MemoryPressureCondition(nowFunc func() time.Time,
	pressureFunc func() bool,
	recordEventFunc func(eventType, event string),
) Setter

MemoryPressureCondition returns a Setter that updates the v1.NodeMemoryPressure condition on the node.

func NodeAddress

func NodeAddress(nodeIP net.IP,
	validateNodeIPFunc func(net.IP) error,
	hostname string,
	hostnameOverridden bool,
	externalCloudProvider bool,
	cloud cloudprovider.Interface,
	nodeAddressesFunc func() ([]v1.NodeAddress, error),
) Setter

NodeAddress returns a Setter that updates address-related information on the node.

func OutOfDiskCondition

func OutOfDiskCondition(nowFunc func() time.Time,
	recordEventFunc func(eventType, event string),
) Setter

OutOfDiskCondition returns a Setter that updates the v1.NodeOutOfDisk condition on the node. TODO(#65658): remove this condition

func PIDPressureCondition

func PIDPressureCondition(nowFunc func() time.Time,
	pressureFunc func() bool,
	recordEventFunc func(eventType, event string),
) Setter

PIDPressureCondition returns a Setter that updates the v1.NodePIDPressure condition on the node.

func ReadyCondition

func ReadyCondition(
	nowFunc func() time.Time,
	runtimeErrorsFunc func() []string,
	networkErrorsFunc func() []string,
	appArmorValidateHostFunc func() error,
	cmStatusFunc func() cm.Status,
	recordEventFunc func(eventType, event string),
) Setter

ReadyCondition returns a Setter that updates the v1.NodeReady condition on the node.

func VersionInfo

func VersionInfo(versionInfoFunc func() (*cadvisorapiv1.VersionInfo, error),
	runtimeTypeFunc func() string,
	runtimeVersionFunc func() (kubecontainer.Version, error),
) Setter

VersionInfo returns a Setter that updates version-related information on the node.

func VolumeLimits

func VolumeLimits(volumePluginListFunc func() []volume.VolumePluginWithAttachLimits,
) Setter

VolumeLimits returns a Setter that updates the volume limits on the node.

func VolumesInUse

func VolumesInUse(syncedFunc func() bool,
	volumesInUseFunc func() []v1.UniqueVolumeName,
) Setter

VolumesInUse returns a Setter that updates the volumes in use on the node.