node

Documentation

Index

• Constants
• func FilterReady(nodes []corev1.Node) []corev1.Node
• func MaxUnavailableNodeCount(cli client.Reader, policy *nmstatev1.NodeNetworkConfigurationPolicy) (int, error)
• func NetworkStateRefreshWithJitter() time.Duration
• func NodesRunningNmstate(cli client.Reader, nodeSelector map[string]string) ([]corev1.Node, error)
• func ScaledMaxUnavailableNodeCount(matchingNodes int, intOrPercent intstr.IntOrString) (int, error)
• type MaxUnavailableLimitReachedError
  • func (f MaxUnavailableLimitReachedError) Error() string

Constants

const (
	DefaultMaxunavailable = "50%"
	MinMaxunavailable     = 1
)

const (
	NetworkStateRefresh          = time.Minute
	NetworkStateRefreshMaxFactor = 0.1
)

Functions

func FilterReady

func FilterReady(nodes []corev1.Node) []corev1.Node

func MaxUnavailableNodeCount

func MaxUnavailableNodeCount(cli client.Reader, policy *nmstatev1.NodeNetworkConfigurationPolicy) (int, error)

func NetworkStateRefreshWithJitter

func NetworkStateRefreshWithJitter() time.Duration

NodeNetworkStateRefreshWithJitter add some jitter to to the refresh rate so it does not hit apiserver at the same time.

func NodesRunningNmstate

func NodesRunningNmstate(cli client.Reader, nodeSelector map[string]string) ([]corev1.Node, error)

func ScaledMaxUnavailableNodeCount

func ScaledMaxUnavailableNodeCount(matchingNodes int, intOrPercent intstr.IntOrString) (int, error)

Types

type MaxUnavailableLimitReachedError

type MaxUnavailableLimitReachedError struct{}

func (MaxUnavailableLimitReachedError) Error

func (f MaxUnavailableLimitReachedError) Error() string